与activeMQ整合-1

<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);

    }  

}