是否可以镜像 ActiveMQ 中的单个队列?

2023-12-13

我在生产系统中运行 ActiveMQ。我们的一些队列数量非常多,有些队列数量非常少。我有兴趣镜像低容量队列之一,以便我可以围绕收到的消息构建非正式的监视服务。

很遗憾,我能找到的唯一文档似乎暗示镜像队列是全有或全无:您要么为您拥有的每个队列创建一个主题(并遭受复制流经系统的每条消息的性能损失),要么您不能在以下位置使用该功能全部。

是否没有办法为单个已知队列名称启用此有用的功能?


您可以像这样镜像单个队列:

<destinationInterceptors>
    <virtualDestinationInterceptor>
        <virtualDestinations>
            <compositeQueue name="YOUR.QUEUE" forwardOnly="false">
                <forwardTo>
                    <queue physicalName="MIRROR.OF.YOUR.QUEUE"/>
                </forwardTo>
            </compositeQueue>
        </virtualDestinations>
    </virtualDestinationInterceptor>
</destinationInterceptors>

您可以找到虚拟目的地的文档here.

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

是否可以镜像 ActiveMQ 中的单个队列? 的相关文章

  • ActiveMQ NMS C# 对象消息使用什么序列化方法?

    我计划使用 Apache NMS 进行 ActiveMQ 消息传递 并且想知道我发送的对象将使用什么序列化方法 XML 二进制 什么控制序列化以及如何自定义它 有人有使用 C 对象执行此操作的经验吗 您知道有哪些陷阱吗 IObjectMes
  • Rabbitmq-设计消息重放服务

    我正在尝试设计一种重播机制 使用户能够重播队列中的消息 对于包含多个队列和多个消费者的交换器 我提出的最佳设计是 创建一个记录器服务 它将 创建一个队列并将所有路由键绑定到它 消耗来自交换器的所有消息 将所有消息保存到数据库 订阅者请求重播
  • 低延迟、大规模消息队列

    我正在重新思考 Facebook 应用程序和云计算时代的大型多人游戏 假设我要在现有开放协议之上构建一些东西 并且我想为 1 000 000 个同时玩家提供服务 只是为了解决问题 假设每个玩家都有一个传入消息队列 用于聊天等 平均还有一个传
  • 网络故障后重新连接ActiveMQ服务器

    我们正在使用 ActiveMQ 5 8 0 通过 TCP 将 Java 应用程序连接到另一个系统 请求 回复 与对临时队列的回复同步 与我们的客户端及其相应部分配合良好 但我们不确定如何处理 异常 情况 例如短暂的网络故障 我们正在测试应用
  • ActiveMQ:如何使旧消息出队?

    我正在学习如何使用ActiveMQ 现在我们面临以下问题 假设我在 ActiveMQ 上有一个名为 topic test 的主题 它有两个订阅者 在特定时刻 我只有一个订阅者在等待消息 而生产者则为我上面提到的主题发送一条消息 好的 连接的
  • 使用 JMS 中的 CCDT 文件连接到 IBM MQ

    我尝试使用 JMS 和客户端通道定义表 CCDT 连接到 IBM MQ 当我单独指定 MQ 属性时 我能够成功连接到 QueueManager 但是当我尝试使用 CCDT 文件时 出现以下异常 由于客户端通道定义表 CCDT 用于确定客户端
  • 在序列/类图中将消费/生产事件表示为从微服务到消息队列[Kafka]的UML组件

    我有一个生成一些事件的用例 消费其他微服务生成的事件以及自己生成的事件 如何在序列图 类图中表示 Kafka 系统 运行中的微服务以及生产 消费事件 在 UML 中 我们有一个来自 DB 的特殊图表 我们有 Kafka 和 cron 作业的
  • ActiveMQ JMS XA Atomikos - 事务未启动错误

    情况是我们想要使用 XA 事务来协调 ActiveMQ 和 Hibernate Sql Server 2008 之间的活动 我们正在使用 春季3 0 5 休眠3 6 2 ActiveMQ 5 5 0 原子3 7 我们看到与尚未启动的事务相关
  • 在 Kafka 中设计生产者和消费者组件

    我在用Kafka and Zookeeper作为我的数据管道的主要组件 该管道每秒处理数千个请求 我在用Samza作为我需要对数据进行小型转换的实时数据处理工具 我的问题是我的一位消费者 比方说ConsumerA 消耗了几个主题Kafka并
  • 在高性能Java应用程序中异步处理低速消费者(数据库)的最佳方式是什么

    One EventHandler 数据库消费者 Disruptor调用数据库中的存储过程 速度太慢 以至于阻塞Disruptor一段时间了 因为我需要Disruptor继续运行而不阻塞 我正在考虑添加一个额外的队列 以便EventHandl
  • JMS/消息队列的实际使用? [关闭]

    Closed 这个问题需要多问focused help closed questions 目前不接受答案 我刚刚阅读了一些有关 JMS 和 Apache ActiveMQ 的内容 想知道这里的人们使用 JMS 或类似的消息队列技术在现实世界
  • ActiveMQ:如何以编程方式监控嵌入式代理

    我想从代码内部监控嵌入式 ActiveMQ 5 8 代理 如何才能做到这一点 我需要 JMX 连接吗 我想防止暴露 JMX 有没有办法访问org apache activemq broker jmx http activemq apache
  • 为什么需要消息队列来与 Web 套接字聊天?

    我在互联网上看到了很多使用 Web 套接字和 RabbitMQ 进行聊天的示例 https github com videlalvaro rabbitmq chat https github com videlalvaro rabbitmq
  • 可以从 http(javascript 客户端)直接向 Amazon SQS 发送请求吗?

    是否可以直接从 JavaScript 向 Amazon 的 SQS 发送消息请求 我正在尝试创建一个日志系统 并且希望绕过将请求发送到中间人服务器 另外 有人知道我可以利用这个解决方案的任何替代方案吗 SQS 事实上所有 aws 服务 都公
  • 基于 Spring Boot AMQP 的 JmsListener 在 TextMessage 上失败

    我有一个 Spring Boot 应用程序 在检索类型的 JMS 消息时遇到问题TextMessage来自 ActiveMQ 代理 如果消费者尝试从代理检索消息 它无法自动将消息转换为 TextMessage 而是将其视为 ByteMess
  • 如何将 activemq-core.xsd url 与 jar 文件中找到的 activemq.xsd 关联?

    有人知道如何关联activemq core xsd网址与activemq xsd在 jar 文件 activemq core 5 2 0 jar 中找到 我在互联网上找到了一些解决方案 但没有成功 我收到此错误 Caused by org
  • 使用 RabbitMq 锁定和批量获取消息

    我正在尝试以一种更非常规的方式使用 RabbitMq 尽管此时我可以根据需要选择任何其他消息队列实现 消费者不会将 Rabbit 推送消息留给我的消费者 而是连接到一个队列并获取一批 N 条消息 在此期间它会消费一些消息 并可能拒绝一些消息
  • 如何使用 PHP 设置 Beanstalkd

    最近我一直在研究 Beanstalkd 与 PHP 的使用 我学到了很多东西 但对服务器上的设置等有一些疑问 我认为它是这样工作的 我在 Ubuntu 服务器上安装 Beanstalkd 和所有依赖项 例如 libevent 然后我启动 B
  • 在 PHP 中使用消息队列与普通 Cron 作业之间的区别

    我们有一个基于 PHP 构建的大型 Web 应用程序 该应用程序允许安排推文和墙贴 并且有从服务器发出的预定电子邮件 我所说的 计划 是指这些 PHP 脚本计划在特定时间运行cron 大约有 7 个 PHP 文件可以完成上述工作 我一直听说
  • ActiveMQ 的 @SendTo 注释无提示地失败

    我试图使用 SendTo 注释将 JMS 消息推送到 SpringBoot 应用程序中的独立 ActiveMQ 代理 但是执行完成时没有错误 异常 但消息未排队 相反 如果我使用 JmsTemplate 在代码中注释 消息将排队 使用 Se

随机推荐

  • 如果我向 application.properties 添加任何值,Spring Boot 项目就会崩溃

    我只是想将环境变量添加到我的项目中 无论我添加什么到我的application properties文件 程序崩溃并且pom xml突然变得无效并在我的 IDE 中突出显示为红色 例如 如果我将其添加到我的application prope
  • 什么时候允许调用“BarcodeScanner.GetDefaultAsync()”?

    我正在尝试使用新的Windows 8 1 服务点 API对于条形码扫描仪 如果我打电话GetDefaultAsync 从以下任何位置 它返回null App OnLaunched 第一页 Loaded 第一页OnNavigatedTo 第一
  • 直接在默认浏览器中打开Shiny App

    通常 闪亮的应用程序通过 R Studio 中的内置浏览器打开 是否可以直接在网络浏览器 例如 Google Chrome 中打开应用程序 而无需通过 R Studio 在我的 Rstudio 版本 0 98 1103 中 我可以更改运行应
  • 正则表达式匹配 JavaScript 中字符串的全部或初始部分

    我正在尝试找出一个正则表达式 它将与以下条件匹配 我要匹配的字符串 var txt This is Regex 用户可以输入如下内容 这个 有效 Th 有效 这是 有效 这是Reg 有效 这是正则表达式 有效 Tis 无效 是无效的 Reg
  • CountDownLatch 与信号量

    使用有什么好处吗 java util concurrent CountdownLatch 代替 java util concurrent Semaphore 据我所知 以下片段几乎是等效的 1 信号量 final Semaphore sem
  • 使用包含图表 5.5.0 的 JRViewer 报告和 jasper 报告打印

    当我使用 JasperReports 创建报告而不使用图表形式 Java 应用程序时 我从 jbutton 调用它 我在 JRViewer 上收到报告 这意味着当我没有在此报告中放入任何图表时 我的应用程序会生成报告 但一旦我修改此报告并添
  • 当软件包已安装时,Conda 需要 20 多分钟来解决环境问题

    当我输入时尝试运行conda update n base conda conda 在 解决环境 上挂了大约 20 分钟 然后返回了一个不包含 conda 更新版本的软件包计划 下面提供了退回的包裹计划 NOTE conda update a
  • 使用 C# 以编程方式检测 Windows 登录尝试

    我想开发一个 Windows 窗体应用程序来监视我的网络计算机登录 注销和登录尝试详细信息 并根据检测执行某些操作 例如向管理员发送一些通知 我尝试过的 我读到了有关 Windows 服务 Windows 任务计划程序和使用任务计划程序进行
  • 如何在 Java 中打开 equals 语句以接受多个参数?

    我有一个梦想 在这个梦中 我可以替换这样的结构 if aLongVariableName equals classInstance aPropertyOfThatInstance aLongVariableName equals class
  • 如何使用 swift 4 在 iOS 11 上播放声音?我把 mp3 文件放在哪里?

    我看了很多教程 但是当我单击按钮 激活功能播放声音 时 声音不播放 我看到了 stackoverflow 推荐的代码 但什么也没有 我把mp3文件信息asset xcasset 这是正确的 SWIFT 4 Xcode 9 1 import
  • 自动将 Excel 文件转换为 Google Sheets

    我有一个使用保存电子邮件和附件插件的谷歌帐户 https chrome google com webstore detail save emails and attachmen nflmnfjphdbeagnilbihcodcopheceb
  • Pandas 无法计算具有重复轴的 isin

    我的数据框是这样的 userid codeassigned timestamp 15 553938 M1 1499371200000 15390 527638 M2 1599731200000 15389 521638 M2 1399901
  • 一个类只有 5 个实例 [关闭]

    很难说出这里问的是什么 这个问题是含糊的 模糊的 不完整的 过于宽泛的或修辞性的 无法以目前的形式得到合理的回答 如需帮助澄清此问题以便重新打开 访问帮助中心 我希望在整个应用程序生命周期中只有 5 个类的实例 我怎样才能实现这个目标 如果
  • 此版本的应用程序未配置为通过 Google Play 计费[重复]

    这个问题在这里已经有答案了 可能的重复 此版本的应用程序未配置为通过 Google Play 计费 我已经在 Android 市场上有一个应用程序 带有应用程序内购买 我的问题是应用内购买功能无法正常工作 我再次重写了代码 现在我想运行该应
  • 如何在 Hibernate 应用程序中处理数据库空值?

    由于数据库表中的空值 我收到 org hibernate PropertyAccessException 异常如何处理 我的文件是 获取测试 java package com raj java hiberanteDemos import o
  • 是否可以将 NFC 信号从 NFC 读/写器发送到 Iphone

    我正在创建一个移动应用程序 它根据 PC 上生成的 ID 获取数据 我想将此 ID 作为文本字符串从我的 NFC 设备传递 当用户触摸 NFC 设备时 该设备支持读取和写入 iPhone 设备 这可能吗 我使用 Acr 122u 作为 NF
  • 在android中设置listview滚动动画

    我想为一个设置动画ListView当用户滚动ListView 我正在设置动画ListView加载时 但我想设置滚动动画 这是我在 eclipse 中的动画文件
  • Linkedin v2 API 图片上传出现错误 400 Bad Request

    当我每次尝试使用 LinkedIn v2 API 上传图像时 都会收到 400 Bad request 错误 参考资料取自这里 Link 我在邮递员中执行的步骤 步骤1 应用程序编程接口 https api linkedin com v2
  • MySql修改预购树创建url

    这个问题是基于我之前的问题堆栈溢出 这次我尝试使用修改后的预购树方法为页面表中的所有行生成 url 以下是 MySql 表 注意 我添加了 父 列 只是为了让查看者了解类别表中的父子关系 实际的Modified Preorder Tree方
  • 是否可以镜像 ActiveMQ 中的单个队列?

    我在生产系统中运行 ActiveMQ 我们的一些队列数量非常多 有些队列数量非常少 我有兴趣镜像低容量队列之一 以便我可以围绕收到的消息构建非正式的监视服务 很遗憾 我能找到的唯一文档似乎暗示镜像队列是全有或全无 您要么为您拥有的每个队列创