SpringBoot与ActiveMQ整合的步骤

  org.springframework.boot
  spring-boot-starter-activemq

/**
 * 消息生产者
 * @author Administrator
 **/
@RestController
public class QueueController {
 @Autowired
 private JmsMessagingTemplate jmsMessagingTemplate;
 @RequestMapping("/send")
 public void send(String text){
 jmsMessagingTemplate.convertAndSend("itcast", text);
 }
}

@Component
public class Consumer {
 @JmsListener(destination="itcast")
 public void readMessage(String text){
 System.out.println("接收到消息："+text);
 } 
}

@RequestMapping("/sendmap")
 public void sendMap(){
 Map map=new HashMap<>();
 map.put("mobile", "13900001111");
 map.put("content", "恭喜获得10元代金券"); 
 jmsMessagingTemplate.convertAndSend("itcast_map",map);
 }

@JmsListener(destination="itcast_map")
 public void readMap(Map map){
 System.out.println(map); 
 }