[Java] Spring Boot与ActiveMQ整合的步骤

<dependency>
  <groupid>org.springframework.boot</groupid>
  <artifactid>spring-boot-starter-activemq</artifactid>
</dependency>

/**
 * 消息生产者
 * @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); 
 }