如何以及在何处使用 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)

  1. 没有消息发送给关联消费者
  2. 消息仍在队列中排队
  3. 能够浏览队列
  4. 队列的所有 JMX 计数器都可用且正确。

添加: Apache ActiveMQ(版本 5.16.2)

但我不知道在哪里创建JmsListenerEndpointRegistry 的bean 并调用启动和停止方法。 示例代码将不胜感激。谢谢。

JmsListenerEndpointRegistry 由 Spring 引导自动配置。

简单地@Autowired它进入控制class,给JmsListener一个id和stop/start它使用id。

注意:这不使用您引用的 AMQ 功能;它只是告诉侦听器容器 stop/start 接收消息。