Spring Boot基于Active MQ实现整合JMS

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-activemq</artifactId>
 <version>2.2.7.RELEASE</version>
</dependency>

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;

import javax.jms.Destination;

@Service("producer")
public class Producer {
 /**
  * 也可以注入JmsTemplate，JmsMessagingTemplate对JmsTemplate进行了封装
  */
 @Autowired
 private JmsMessagingTemplate jmsTemplate;

 /**
  * 发送消息，destination是发送到的队列，message是待发送的消息
  *
  * @param destination
  * @param message
  */
 public void sendMessage(Destination destination, final String message) {
  jmsTemplate.convertAndSend(destination, message);
 }
}

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Component;

@Component
public class ConsumerListener {
 private static Logger logger = LoggerFactory.getLogger(Consumer.class);
 /**
  * 使用JmsListener配置消费者监听的队列
  * @param receivedMsg 接收到的消息
  */
 @JmsListener(destination = "myDest.queue")
 public void receiveQueue(String receivedMsg) {
  logger.info("Consumer收到的报文为: {}", receivedMsg);
 }
}

import org.apache.activemq.command.ActiveMQQueue;
import javax.jms.Destination;

@Autowired
private Producer producer;
@Test
public void jmsActiveMqTest() throws InterruptedException {
 Destination destination = new ActiveMQQueue("myDest.queue");
 for (int i = 0; i < 21; i++) {
  producer.sendMessage(destination, String.format("My name is Wiener%s", i));
 }
}