0
我在Redhat ActiveMQ中有两个队列,一个用于消耗,另一个用于生成和消耗对象消息。JMSTemplate和DefaultMessageListenerContainer
一旦从它被推至第二队列,以便进一步处理主队列消耗,但是在使用JmsTemplate的消息被越来越随机丢失,
我使用与ActiveMQConnectionFactory相同豆在DMLC容器2,并用JmsTemplate
让我知道如何确保消息不会在JmsTemplate中丢失。
感谢您的回应,但没有其他设置或环境正在运行,日志显示消息已经进入第二个队列,之后从未被定义为消息未进入队列的消息,在那段时间内没有任何来自ActiveMQ代理的错误。不确定是否需要添加任何其他故障切换参数或与ActiveMQ ConnectionFactory有关的任何其他参数。 – Joe
明白了。你可以在这里发布你的连接工厂参数吗? –
@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