可以在@JmsListener SpringBoot中选择性禁用队列消耗吗？

Question

我正在使用SpringBoot和@JmsListener从同一个QManager中的多个队列中检索IBM MQ消息。到目前为止，我可以得到没有任何问题的消息。但也有可能出现这样的情况，我不得不暂时停止使用其中一个队列中的MSG。它不一定是动态的。

我没有使用任何自定义ConnectionFactory方法。需要时，我想在application.properties中进行配置更改，以禁用特定的队列消耗并重新启动进程。这可能吗？找不到此方案的任何特定信息。感谢您的任何建议。TIA。

@Component
public class MyJmsListener {
  @JmsListener(destination = "{ibm.mq.queue.queue01}")
  public void handleQueue01(String message) {
      System.out.println("received: "+message);
  }

  @JmsListener(destination = "{ibm.mq.queue.queue02}")
  public void handleQueue02(String message) {
      System.out.println("received: "+message);
  }
} 


application.properties

ibm.mq.queue.queue01=IBM.QUEUE01
ibm.mq.queue.queue02=IBM.QUEUE02

Answer 1

如果给每个JmsListener提供一个id属性，那么可以使用JmsListenerEndpointRegistry bean分别启动和停止它们。

registry.getListenerContainer(id).stop();