2017-07-27 31 views
0

我在Redhat ActiveMQ中有两个队列,一个用于消耗,另一个用于生成和消耗对象消息。JMSTemplate和DefaultMessageListenerContainer

一旦从它被推至第二队列,以便进一步处理主队列消耗,但是在使用JmsTemplate的消息被越来越随机丢失,

我使用与ActiveMQConnectionFactory相同豆在DMLC容器2,并用JmsTemplate

让我知道如何确保消息不会在JmsTemplate中丢失。

回答

0

我会再仔细检查一下,没有其他人检查队列中的消息。如果在某种开发环境中运行了多个应用程序实例 - 它们可能会竞争消息。它可能是另一个开发者使用与ActiveMQ或开发/阶段环境相同的连接字符串启动另一个应用程序实例。

+0

感谢您的回应,但没有其他设置或环境正在运行,日志显示消息已经进入第二个队列,之后从未被定义为消息未进入队列的消息,在那段时间内没有任何来自ActiveMQ代理的错误。不确定是否需要添加任何其他故障切换参数或与ActiveMQ ConnectionFactory有关的任何其他参数。 – Joe

+0

明白了。你可以在这里发布你的连接工厂参数吗? –

+0

@Bean public ActiveMQConnectionFactory amqConnectionFactory() {0}最终的ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); connectionFactory.setBrokerURL(brokerUrl); connectionFactory.setPassword(password); connectionFactory.setUserName(user); connectionFactory.setTrustAllPackages(true); connectionFactory.setRedeliveryPolicy(redeliveryPolicy()); return connectionFactory; } – Joe

相关问题