ActiveMQ消息回流

2024-06-06 16:26:50

可能有时候我们会遇到消息丢失的场景，比如broker1和broker2通过networkConnector连接，一些消费者连接到broker1,消费broker2的消息。broker2的消息先被broker1消费掉，然后broker1转发给这些消费者。但是转发部分消息的时候，broker1挂掉了或者重启了。这些消费者发现broker1连接失败，通过failover连接到broker2上去了。但是broker2之前转发给broker1的还有部分消息没有被消费，除非有其他的消费者连接到broker1上面去消费，这时候，怎么办呢？

destinationPolicy上有一个选项replayWhenConsumers，这个选项使得broker1上有需要转发的消息但是没有消费时，把消息回流到他原始的broker,同时把enableAudit设置为false，为了防止消息回流后被当做重复消息而不被分发。

<destinationPolicy>

<policyMap>

<policyEntries>

<policyEntrytopic=">" enableAudit="false">

<networkBridgeFilterFactory>

<conditionalNetworkBridgeFilterFactoryreplayWhenNoConsumers="true" />

</networkBridgeFilterFactory>

<pendingMessageLimitStrategy>

<constantPendingMessageLimitStrategylimit="1000"/>

</pendingMessageLimitStrategy>

</policyEntry>

</policyEntries>

</policyMap>

</destinationPolicy>

ActiveMQ消息回流相关推荐

ActiveMQ—消息特性（延迟和定时消息投递）
ActiveMQ消息特性:延迟和定时消息投递(Delay and Schedule Message Delivery) 转自:http://blog.csdn.net/kimmking/article ...
【转】ActiveMQ消息传送机制以及ACK机制详解
2019独角兽企业重金招聘Python工程师标准>>> 本文转载自 http://shift-alt-ctrl.iteye.com/blog/2020182 AcitveMQ是作为一 ...
ActiveMQ消息传送机制以及ACK机制详解
2019独角兽企业重金招聘Python工程师标准>>> AcitveMQ是作为一种消息存储和分发组件,涉及到client与broker端数据交互的方方面面,它不仅要担保消息的存储安全 ...
activemq消息持久化_ActiveMQ 5.x中的消息持久性
activemq消息持久化我被问了很多关于ActiveMQ如何存储消息(或在某些情况下不存储)的基本知识. 这是它的高级解释. 注意,上下文在JMS中. 如果您使用ActiveMQ的非JMS客户端( ...
activemq消息持久化_将ActiveMQ持久消息传递性能提高25倍
activemq消息持久化 Apache ActiveMQ,JBoss A-MQ和Red Hat Apache ActiveMQ是一个非常受欢迎的开源消息传递代理,由创建(和从事) Apache Ka ...
ActiveMQ消息优先级：工作原理
关于ActiveMQ的消息优先级支持 , 邮件列表上通常会不断出现一些问题,以及有关观察到的行为和"真正支持什么"的好问题? 我希望可以帮助您了解幕后情况以及可以支持的优先级. 详 ...
JMS学习六（ActiveMQ消息传送模型）
JMS学习六(ActiveMQ消息传送模型) ActiveMQ 支持两种截然不同的消息传送模型:PTP(即点对点模型)和Pub/Sub(即发布 /订阅模型),分别称作:PTP Domain 和Pub/ ...
JMS学习八（ActiveMQ消息持久化）
JMS学习八(ActiveMQ消息持久化) ActiveMQ的消息持久化机制有JDBC,AMQ,KahaDB和LevelDB,还有一种内存存储的方式,由于内存不属于持久化范畴,而且如果使用内存队列,可 ...
SpringBoot集成ActiveMq消息队列实现即时和延迟处理
原文链接:https://blog.csdn.net/My_harbor/article/details/81328727 一.安装ActiveMq 具体安装步骤:自己谷歌去二.新建springbo ...

最新文章

热门文章