Spring 与 IBM MQ 集成

Question

我已经阅读了有关 EJB MDB 的内容，它提供异步和线程安全地使用来自队列的消息。

我在 IBM MQ 依赖项中搜索 spring，我找到了 "mq-jms-spring-boot-starter"，但我没有得到任何显示来自 queue/topic.

的消费异步数据的示例

是否有人使用此依赖项来解决 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());

}
}

Spring 与 IBM MQ 集成

Spring integration with IBM MQ

spring

ejb

spring-jms

spring-boot

ibm-mq