与 IBM MQ 的 Spring 集成

Question

我已经阅读过 EJB MDB，它提供了从队列异步和线程安全的消费消息。

我正在为 spring 搜索 IBM MQ 依赖项，我找到了“mq-jms-spring-boot-starter”，但我没有得到任何显示来自队列/主题的消费异步数据的示例。

是否有人使用此依赖项来解决 spring 中的异步和线程安全问题？

如果不使用此依赖项，那么 Spring 中还有哪些其他选项可以使用 IBM MQ 来实现消费异步消息读取？

Answer 1

我找到了解决方案。我们必须使用 IBM MQ 依赖 https://github.com/ibm-messaging/mq-jms-spring 然后我们可以使用以下示例代码异步访问队列。

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

}
}