message-listener

2热度

1回答

Setsessiontransacted如何在JMSTemplate和DefaultMessageListenerContainer与Pub /子模型中工作

我正在使用发布者/订阅者模型，在该模型中使用JMSTemplate将消息发布到主题上。我使用defaultmessagelistenercontainer来订阅和接收消息。我知道我可以在两个配置中设置sessionTransacted true。但如果我把会发生什么情况1）只有JMSTemplate setsessionTransacted为true？ 2）only messagelisten

0热度

1回答

ActiveMQ的故障转移

代理网址 failover:(tcp://broker1:61616,tcp://broker2:61616)?randomize=false&jms.useAsyncSend=false&jms.dispatchAsync=false&maxReconnectAttempts=2&maxReconnectDelay=100 我注册的活跃代理的消息监听器中保存消费者第二个经纪人。你能给我点亮吗

0热度

1回答

是MessageDrivenContext.setRollbackOnly（）需要队列的放置权限

当我们使用MessageDrivenContext.setRollbackOnly()时，Container会回滚交易竞赛，所以邮件会被放回队列JMS。是否需要明确的看跌许可该队列或作为其交易水平，使容器将处理它没有明确的看跌许可。我使用IBM MQ。

1热度

1回答

使用JMS选择器与内存中的过滤

我有一个需求来读取队列中的消息，通过虚拟主题进行填充。考虑让JMS选择器只读取我在侦听器中需要的消息 - 但由于我不想让消息进入队列 - 我可以实现另一个侦听器，它可以读取剩余的消息并只是确认它，或者我可以做一个单独的监听器，它没有JMS选择器，但在内存中进行过滤。建议采用哪种方法？

0热度

1回答

[RabbitMQ] [Spring]如何获取最终交换名称？

对于Exchange与Exchange的结合definintion public class RabbitRecieveTest implements MessageListener { @Override public void onMessage(Message message) { String firstExchange = message.getMessagePro

1热度

1回答

Spring AMQP对消息超时采取行动

我正在使用Spring AMQP进行异步消息传递。我的模型假定有两个应用程序A和B，都是生产者和消费者。 A向B发送工作请求并开始监听。 B正在监听作业请求，并且当作业完成时，启动作业并定期向A发送进度消息。 B在作业完成后向作业完成消息发送作业完成消息。 A消耗进度消息，直到工作完成消息到来，然后A存在。我在课程级别上使用@RabbitListener，在方法级别上使用@RabbitHandl

1热度

2回答

使用MessageListener的JMS MessageConsumer在ActiveMQ关闭时终止

尝试让JMS MessageConsumer在ActiveMQ重新启动后继续存在，因此可以使用故障切换传输协议重新连接。但是，它会在ActiveMQ关闭时终止。这看起来像报道和“解决”的错误，但我仍然在ActiveMQ中5.10.0的最新版本看到这我用下面的行家依赖 <dependency> <groupId>org.apache.activemq</groupId>

1热度

1回答

JMS：可以是MessageListener的onMessage中的消息null？

如果我的MessageConsumer正在实现MessageListener（JBoss JMS 1.1 API），是否有消息可能在Method onMessage（消息）中为空的情况？ import javax.jms.MapMessage; import javax.jms.Message; import javax.jms.MessageListener; @MessageDriv

0热度

1回答

限制时间，在此期间从JMS队列读

我具有以下设置：外部应用写入到JMS队列 JMS队列也是外部，所以没有配置可能这里使用ActiveMQ在Glassfish上运行的现有应用程序将服务器连接到jms队列现有应用程序是一个实现MessageListener接口的MessageDriven bean（当它们被放入队列时正在处理消息）新要求说，这些消息只能从02:00时间框架内进行处理，以04:00 我最好如何限制了Message

0热度

1回答

DMLC消息消耗和确认

这是Difference between AUTO_ACKNOWLEDGEMENT mode with and without Spring JMS的后续问题。我正在使用DMLC，并且我的并发使用者数为1.预取限制为> 1.我收到消息并在侦听器执行之前进行确认。所以，当侦听器正在执行时，代理具有更多的消息，并按照预取设置将消息发送给使用者。由于听众仍在执行，消费和确认如何对后续消息起作用？是否