spring-boot - 如何使用 MessageListener 声明队列

Question

我使用 Spring Boot 2.2，需要通过 JMS 接收消息。

我看到我们可以使用注释

@Component
public class JMSReceiver {

    @JmsListener(destination = "queue")
    public void receiveMessage(String message) {
        System.out.println("Received <" + message + ">");
    }
}

实现MessageListener:

@Component
public class JMSReceiver implements MessageListener {

    @Override
    public void onMessage(Message message) {
       ...    
    }
}

通过MessageListener我们如何声明我们使用的队列？

Answer 1

您不在 MessageListener 实现上声明队列，而是在 MessageListenerContainer 上声明队列。

例如:

  @Bean
  public MessageListenerContainer messageListenerContainer() {
      DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
      container.setConnectionFactory(connectionFactory());
      container.setDestinationName("queue"); // Set the queue name here.
      container.setMessageListener(jmsReceiver()); // Your JMS receiver message listener.
      return container;
  }