8得票1回答
高的Spring JMS DefaultMessageListenerContainer.receiveTimeout参数意味着什么?

我正在参与一个实现了IBM MQ监听Spring JMS应用程序的项目,但我对DefaultMessageListenerContainer中的“receiveTimeout”参数理解有困难。 与互联网上的源代码相比,我认为我的项目有点特殊,因为我们将“receiveTimeout”参数设置...

8得票1回答
Spring 4的CachingConnectionFactory与JMS 2.0一起使用时无法正确缓存生产者。

我们刚刚升级到了Spring 4和JMS 2.0。我们使用了一个CachingConnectionFactory和一个JmsTemplate来发布消息,并注意到当发布到一个目的地时,第一次尝试工作正常,然后进一步尝试发布到相同的目的地会导致以下异常: Caused by: javax.jms...

8得票1回答
使用 @DependsOn 注释一个 bean 是否意味着依赖的 bean 将被实例化或初始化?

我正在使用Spring 3.0.2。我有两个相对简单的bean定义。其中一个具有@PostConstruct(Bean 'A'),它触发了一系列事件,@DependsOn bean(Bean 'B')需要准备好。然而,即使我声明Bean 'A'依赖于Bean 'B',Bean 'A'的事件(生...

8得票3回答
使用Spring启动和停止JMS监听器

问题是如何使用以下方式临时停止和启动使用Spring创建的JMS监听器: <amq:connectionFactory id="exampleJmsFactory" brokerURL="tcp://${jms.broker.url}" /> <jms:listener-...

8得票3回答
如何在Spring Java配置中为单个MessageListenerContainer添加多个JMS MessageListner

我在 spring-config.xml 文件中有以下的 XML 代码: <jms:listener-container acknowledge="auto" connection-factory="cachedConnectionFactory" container-...

8得票4回答
目的地的JMS消息监听器调用程序设置失败,正在尝试恢复。

在我的应用程序中运行集成测试时,我在failsafe测试报告中得到以下错误消息,这是我其中一个集成测试的结果: listener.DefaultMessageListenerContainer,WARN,Setup of JMS message listener invoker failed...

8得票1回答
DefaultJmsListenerContainerFactory与DefaultMessageListenerContainer的区别

使用DefaultJmsListenerContainerFactory相比于使用DefaultMessageListenerContainer有哪些优势? 如果我直接配置DMLC,我可以通过调用isRunning()来检查状态。此外,我也可以启动和停止DMLC。 然而,根据新的Sprin...

8得票1回答
SpringBoot JMS监听器:无法为目标刷新JMS连接

我有一个Spring Boot应用程序,它通过组件类监听IBM MQ队列的@JmsListener注释如下。MQ属性(主机名,通道,端口等)来自yaml文件设置。 @JmsListener(destination = "<QueueName>") public void re...

7得票1回答
如何在AUTO_ACKNOWLEDGE JMS会话方案中模拟消息重发?

在下面的测试中,我试图模拟以下场景: 启动一个消息队列。 启动一个设计用于在消息处理期间失败的消费者。 生产一条消息。 消费者开始处理消息。 在处理过程中抛出异常以模拟消息处理失败。停止失败的消费者。 启动另一个消费者,意图获取被重新发送的消息。 但我的测试失败了,消息没有被重新发送到...

7得票1回答
使用单个Spring Boot应用程序监听多个IBM MQ

我需要监听多个队列(存在于同一队列管理器中)。我有一个可以监听单个队列的Spring Boot应用程序代码。但是是否有任何方法可以从单个Spring Boot应用程序连接到多个队列? 此外,有没有办法在运行时从一个队列切换侦听器到另一个队列? 我有读取单个队列的代码,如下所示: publ...