IBM MQ 侦听器和消息适配器

Question

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

Answer 1

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

IBM MQ Spring Examples

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

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());
  
}
}