如何以及在何处使用 JmsListenerEndpointRegistry 使用 Spring Boot 启动和停止功能?
How and where to use JmsListenerEndpointRegistry start and stop function using SpringBoot?
我想stop/pause队列以便(https://issues.apache.org/jira/browse/AMQ-5229)
- 没有消息发送给关联消费者
- 消息仍在队列中排队
- 能够浏览队列
- 队列的所有 JMX 计数器都可用且正确。
添加: Apache ActiveMQ(版本 5.16.2)
但我不知道在哪里创建JmsListenerEndpointRegistry 的bean 并调用启动和停止方法。
示例代码将不胜感激。谢谢。
JmsListenerEndpointRegistry
由 Spring 引导自动配置。
简单地@Autowired
它进入控制class,给JmsListener
一个id
和stop/start它使用id。
注意:这不使用您引用的 AMQ 功能;它只是告诉侦听器容器 stop/start 接收消息。
我想stop/pause队列以便(https://issues.apache.org/jira/browse/AMQ-5229)
- 没有消息发送给关联消费者
- 消息仍在队列中排队
- 能够浏览队列
- 队列的所有 JMX 计数器都可用且正确。
添加: Apache ActiveMQ(版本 5.16.2)
但我不知道在哪里创建JmsListenerEndpointRegistry 的bean 并调用启动和停止方法。 示例代码将不胜感激。谢谢。
JmsListenerEndpointRegistry
由 Spring 引导自动配置。
简单地@Autowired
它进入控制class,给JmsListener
一个id
和stop/start它使用id。
注意:这不使用您引用的 AMQ 功能;它只是告诉侦听器容器 stop/start 接收消息。