如何在队列上设置 ActiveMQ redeliveryPolicy?

2023-12-21

如何在队列上的 ActiveMQ 中设置 redeliveryPolicy?

1)在文档中,请参阅:activeMQ 重新传送 http://activemq.apache.org/redelivery-policy.html,说明您应该在 ConnectionFactory 或 Connection 上设置它。但我想对不同的队列使用不同的值。

2)除此之外,我似乎无法正常工作。在 Spring 中的连接工厂上设置它(我使用的是 activemq 5.4.2. 和 Spring 3.0),如下所示似乎没有任何效果:

<amq:connectionFactory id="amqConnectionFactory" brokerURL="${jms.factory.url}" >
    <amq:properties>
        <amq:redeliveryPolicy maximumRedeliveries="6" initialRedeliveryDelay="15000" useExponentialBackOff="true" backOffMultiplier="5"/>
    </amq:properties>
</amq:connectionFactory>

我还尝试将其设置为定义的队列上的属性,但这似乎也被忽略,因为重新传递发生的时间早于定义的值:

<amq:queue id="jmsQueueDeclarationSnd"  physicalName="${jms.queue.declaration.snd}" >
    <amq:properties>
        <amq:redeliveryPolicy maximumRedeliveries="6" initialRedeliveryDelay="15000" useExponentialBackOff="true" backOffMultiplier="5"/>
    </amq:properties>
</amq:queue>

Thanks


我也使用了上面伊万展示的方法amq:连接工厂

在升级到 ActiveMQ 5.7.0 时,我注意到这不再有效(因为实施了https://issues.apache.org/jira/browse/AMQ-3224 https://issues.apache.org/jira/browse/AMQ-3224)。无论如何,在阅读了我目前使用的 ActiveMQ 论坛上更好的帖子后:-

<amq:queue id="emailQueue" physicalName="emailQueue" />
<amq:queue id="smsQueue" physicalName="smsQueue" />

<!-- Wait 15 seconds first re-delivery, then 45, 135, 405, 1215, 3645 seconds -->
<bean id="redeliveryPolicy" class="org.apache.activemq.RedeliveryPolicy">
    <property name="backOffMultiplier" value="3" />
    <property name="initialRedeliveryDelay" value="15000" />
    <property name="maximumRedeliveries" value="6" />
    <property name="queue" value="*" />
    <property name="redeliveryDelay" value="15000" />
    <property name="useExponentialBackOff" value="true" />
</bean>

<amq:connectionFactory id="jmsFactory" brokerURL="yourProtocol/BrokerURL">
    <property name="redeliveryPolicy" ref="redeliveryPolicy" />
</amq:connectionFactory>

请注意,对于 6 次重试后重新投递失败的任何消息,ActiveMQ 将创建一个 DLQ.emailQueue' 或 DLQ.smsQueue 并将消息放入该队列中(将其从原始队列中出队)。

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

如何在队列上设置 ActiveMQ redeliveryPolicy? 的相关文章

  • ActiveMQ从java获取监听主题的消费者数量

    我希望能够获取同一 JVM 中嵌入式 ActiveMQ 5 4 2 代理从 java 监听主题的消费者数量 JMX 真的是唯一的选择吗 JMX 似乎是一个糟糕的选择 因为它可以选择性地禁用 这篇文章展示了如何使用 JMX 获取连接列表 Ac
  • 如何在 ActiveMQ 5.2 中打开 JMX

    在 ActiveMQ 5 2 中启用 JMX 的正确方法是什么 我见过相互冲突的文档 所以我想知道是否有人知道正确的配置文件更改应该是什么 我想我可以通过更改用于启动 ActiveMQ 的批处理文件来使其工作 但我真的不知道
  • 如何从 Spring JMS 生成 WebSphere MQ 消息?

    我需要以 WebSphere MQ 消息格式生成队列消息 默认情况下 spring 以 JMS 格式生成消息 我用谷歌搜索并了解到WebSphere MQ消息格式包含MQMD和RFH2标头 不知道如何从 Spring 生成这两个 雄猫在哪里
  • ActiveMQ Dead Letter Box.queue - 消息直接发送到那里?

    当使用 JMS 发布者 订阅者元素运行我的 JMeter 测试计划时 它似乎成功运行 并将跟踪数据发送到网页 我可以在JMeter中看到响应数据正常 然而 没有出现任何踪迹 因此 当查看 JMS 浏览器时 消息似乎直接进入 ActiveMQ
  • ActiveMQ 获取入队/出队计数

    在DEBUG模式下 有一个ActiveMQ日志为 09 44 10 666 ActiveMQ Task 1 DEBUG org apache activemq broker region Queue 1687 queue demo toPa
  • JDK21 和 ActiveMQ 6.0.1

    ActiveMQ 安装和测试 一 ActiveMQ 下载 二 ActiveMQ 安装 三 代码测试 1 Pom 依赖 2 YML配置 3 启动类 4 MQ 配置类 5 MQ 消费者
  • 计算 JMS 队列中的消息数

    检查 JMS 队列并获取其中所有消息的最佳方法是什么 如何统计队列中消息的数量 Thanks 使用 JmsTemplate public int getMessageCount String messageSelector return j
  • ActiveMQ:一条待处理消息,但队列为空

    我在使用 ActiveMQ 时遇到了一个奇怪的问题 我有一个队列 似乎有待处理的消息 但是当我打开队列时 没有消息 这里有什么问题吗 真的有消息待处理吗 我怎样才能取回消息或至少看到内容 Screenshot of the pending
  • ActiveMQ从java中删除队列

    如何从java程序中删除activemq中的队列 有类似 session delelteQueue 的东西吗 谢谢M 简单的解决方案 不使用 JMX 将连接转换为 ActiveMQConnection 并使用其 destroyDestina
  • 多个 Activemq 远程代理的 Spring 配置

    如何在spring上下文中配置多个远程activemq代理 不同的IP地址 以下是 1 个远程代理的配置 我正在使用camel来创建路由 用于在多个远程代理中的不同队列中生成和使用消息 根据以下路由 系统如何知道每个队列属于哪个远程代理 项
  • 如何使用 Spring WebSocket 向 STOMP 客户端发送错误消息?

    我正在使用 Spring 的 STOMP over WebSocket 实现和功能齐全的 ActiveMQ 代理 当用户SUBSCRIBE对于一个主题 有一些权限逻辑 必须经过一些权限逻辑 才能成功订阅 我正在使用 ChannelInter
  • ActiveMQ:在没有代理的情况下启动消费者

    我正在编写一个从队列消费的 JMS 客户端 如果重要的话 我的经纪人是 activemq 一项要求是 即使代理关闭 客户端也应该启动 在这种情况下 它的行为应该就像队列中没有消息一样 一旦代理启动并且消息开始出现 就会做出相应的行为 问题是
  • 我如何向 Activemq 发送消息

    我从来不工作JMS 最近我下载了Activemq并更改端口号61616 to 61617 in all conf activemq xml文件 我从命令提示符运行以下命令并在浏览器上打开控制台页面 C Users Infratab Bang
  • ActiveMQ 简单身份验证插件 - 用户管理员无权创建:topic://ActiveMQ.Advisory.Connection

    我修改了我们的 ActiveMQ 配置以使用 ActiveMQ 简单身份验证插件以及具有代理所有权限的单个用户和密码
  • 如何在 AUTO_ACKNOWLEDGE JMS 会话场景中模拟消息重新传递?

    在下面的测试中 我尝试模拟以下场景 消息队列启动 启动设计为在消息处理期间失败的消费者 产生一条消息 消费者开始处理消息 在处理过程中抛出异常来模拟消息处理失败 失败的消费者被停止 另一个消费者启动的目的是接收重新传递的消息 但我的测试失败
  • 如何在Mule中创建独占队列消费者?

    在 ActiveMQ 中 您可以为队列配置独占消费者 例如 Queue Name Here consumer exclusive true 如何在 Mule 中配置像上面这样的独占消费者 您需要对队列名称进行 URL 编码 因为 Mule
  • 由于地址已在使用错误,Activemq 无法运行

    如何解决错误 Java Runtime Oracle Corporation 1 7 0 05 E Program Files Java jdk1 7 0 05 jre Heap sizes current 1004928k free 99
  • 基于 Spring Boot AMQP 的 JmsListener 在 TextMessage 上失败

    我有一个 Spring Boot 应用程序 在检索类型的 JMS 消息时遇到问题TextMessage来自 ActiveMQ 代理 如果消费者尝试从代理检索消息 它无法自动将消息转换为 TextMessage 而是将其视为 ByteMess
  • Spring Web 连接到嵌入 Jboss 服务器 7.1.1 的 HornetQ JMS

    我正在尝试设置 spring web 以通过以下方式连接到远程 Jboss 7 1 1 HornetQ JMSthis http java dzone com articles connecting spring地点 但我收到以下错误 是否
  • IBM MQ - 如何使用多个连接名称连接到队列管理器(一个是故障转移)

    我对 IBM MQ 还很陌生 我的是一个多实例队列管理器 一种情况就像故障转移 即使其中之一已关闭 我如何才能连接到它们 我不确定我的术语是否正确 我现在尝试使用下面的示例进行连接 https raw githubusercontent c

随机推荐

  • Pandas:无法更改列数据类型

    我遵循了建议here https stackoverflow com questions 15891038 pandas change data type of columns更改 pandas 数据框的列数据类型 但是 如果我通过索引号而
  • mysqli_stmt_bind_result 上的 PHP 奇怪的段错误

    当将 PHP 脚本从 PHP 5 2 迁移到 PHP 5 3 时 我偶然发现了以下问题 该脚本的一般用途是数据挖掘 我里面有一个向 MySQL 服务器添加数据的过程 因为它确实是重复的 所以我 不久前 重写了它以使用 MySQLi 特别是准
  • Python 与 Javascript 浮点运算给出了截然不同的答案。我究竟做错了什么?

    Python版本 http code google com p pyglicko source browse glicko py JavaScript 版本 https github com austinyun JS Glicko blob
  • 使用 .html() 时,jQuery 是否会从字符串中删除一些 html 元素?

    我有一个包含完整 html 页面的 var 包括 head html body 等 当我将该字符串传递到 html 函数时 jQuery 会删除所有这些元素 例如 body html head 等 这是我不想要的 我的数据变量包含 那么我的
  • C# 中简单线程池的代码 [关闭]

    就目前情况而言 这个问题不太适合我们的问答形式 我们希望答案得到事实 参考资料或专业知识的支持 但这个问题可能会引发辩论 争论 民意调查或扩展讨论 如果您觉得这个问题可以改进并可能重新开放 访问帮助中心 help reopen questi
  • 在 gelf 连接失败时使用 Symfony 2 / Monolog 防止内部服务器错误

    我正在尝试使用 gelf 格式将日志从 symfony 2 应用程序流式传输到graylog 2 服务器 我的独白配置如下 monolog handlers 8 lt gt 8 graylog type gelf publisher hos
  • DWR 的缺点是什么?

    在内网中使用DWR时 会出现性能或安全问题等缺点吗 直接 Web 远程处理是一种使用 Ajax 请求从 js 文件联系服务器的工具 我要注意的一件事是 与 正常 全页 HTTP 交付相比 您的服务器很可能会受到更多 HTTP 请求的攻击 让
  • 为什么在测试 MediaRecorder 示例时出现致命异常?

    我使用 Android Studio 在真实设备中测试示例 E Android SDK samples android 22 media MediaRecorder 出现以下错误 为什么 样本中是否存在一些错误 顺便说一句 我的 Andro
  • 返回按钮和上次活动

    我的应用程序链接了一些活动 如果您按后退按钮 您会返回到旧的活动 然后您会突然退出应用程序 所以如果它是堆栈上的最后一个活动 我需要显示一条消息 例如 你真的想退出吗 我知道如何覆盖后退按钮 但我不知道如何知道历史中有多少活动 Overri
  • 为 SQL Server 中的字段生成唯一哈希

    我正在编写一个会员提供程序 以便与我们现有的会员基础一起使用 我使用 EF4 1 进行所有数据库访问 我遇到的问题之一是 当数据库最初设置时 关系是以编程方式完成的 而不是在数据库中完成的 一种是如果需要在并非所有用户都需要的列上建立关系
  • 如何在WebRTC对等连接中创建数据通道?

    我正在尝试学习如何创建一个RTCPeerConnection这样我就可以使用DataChannelAPI 这是我根据我的理解尝试过的 var client new mozRTCPeerConnection var server new mo
  • PHP、PDO 和异常

    我目前对于 PDO 有点进退两难 我最近转而从我自己的自定义数据库类中使用它 因为我想利用事务 我面临的问题是如何从已经用 PDO 的 try catch 包装的代码块内部抛出异常 这是一个例子 try PDO code Transacti
  • 如何在React hooks中自动停止setInterval?

    我想构建一个循环进度条 计数到 60 然后自动停止 但它无法停止 我想使用 React hooks 和 useEffect 我的代码在这里 https codesandbox io s nostalgic khorana lijdyo fi
  • 如何在 iOS 15 Xcode 13 中将 TabView tabItem 上的填充图标更改为不填充?

    如何将 iOS 15 Xcode 13 中的 TabView tabItem 上的填充图标更改为不填充 现在看来图标是默认填充的 我的代码 import SwiftUI struct Test Home V View var body so
  • Promise.catch() 在 AngularJS 单元测试中没有捕获异常

    我正在 Typescript 中为我的应用程序编写 Jasmine 单元测试 并通过 Resharper 运行它们 如果处理程序抛出异常 它应该执行一个操作 describe Q Service Test gt var q ng IQSer
  • 边缘会话.cookie_lifetime

    我的网站功能在 Edge 上损坏 尤其是登录 有人告诉我这与session cookie lifetime 对于此事的任何帮助 我将不胜感激 请注意 我不是开发人员 没有任何代码知识 我的一些 php ini 文件 如果有帮助的话 sess
  • 查找上个月

    我见过一些使用的方法dateutil模块来执行此操作 但是有没有一种方法可以在不使用内置库的情况下执行此操作 例如 当前月份是七月 我可以使用datetime now 功能 python 返回上个月的最简单方法是什么 这很简单 gt gt
  • 是否可以在函数内使用 Excel 数组中的单个单元格引用?

    我有一些数据想要放入 LOGEST 函数中 e g x values 0 463 0 609 0 887 y values 0 05 0 1 0 2 For this example I have put the data into the
  • asyncio 和 trio 之间的核心区别是什么?

    今天 我发现了一个名为trio http trio readthedocs io en latest index html它说它自己是一个供人类使用的异步 API 这些词有点相似requests As requests确实是一个不错的库 我
  • 如何在队列上设置 ActiveMQ redeliveryPolicy?

    如何在队列上的 ActiveMQ 中设置 redeliveryPolicy 1 在文档中 请参阅 activeMQ 重新传送 http activemq apache org redelivery policy html 说明您应该在 Co