IBM MQ 侦听器和消息适配器

如何解决IBM MQ 侦听器和消息适配器

是否有为 IBM MQ 定义的侦听器接口，或者我应该使用一个正在运行的线程来实现它，该线程每隔某个频率拉取一次并将消息传递给处理程序？另外，IBM MQ 消息和标准 JMS 消息之间是否有定义的适配器，还是我应该实现自己的适配器？

解决方法

看这里，它有你需要的东西。

您正在寻找这样的东西...

public class Test {

@Bean
public JmsListenerContainerFactory<?> myFactory(
    ConnectionFactory connectionFactory,DefaultJmsListenerContainerFactoryConfigurer configurer) {
  DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
  factory.setConcurrency("5");
  configurer.configure(factory,connectionFactory);
  return factory;
}

@JmsListener(destination = "DEV.QUEUE.1",containerFactory = "myFactory")
public void receiveMessage(String transaction) {
  System.out.println("Received <" + transaction + ">"+ "start time"+System.currentTimeMillis());
  
}
}