Spring与IBM MQ的集成

Question

我读过关于EJB MDB的文章，它提供了从队列异步和线程安全中消耗消息的功能。

我在IBM MQ dependency中搜索spring，找到了“MQ jms spring boot starter”，但我没有得到任何显示队列/主题中使用异步数据的示例。

是否有任何机构使用此依赖项来解决Spring中的异步和线程安全问题？

如果不使用这种依赖关系，那么IBMMQ在Spring中还有哪些其他选项可以实现耗时的异步消息读取？

Answer 1

我找到了解决方案。我们必须使用IBMMQ依赖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());

}
}