springboot与activeMQ入门（1） (2)

  生产者Producer.java代码如下：

@RestController public class Producer { @Autowired private JmsMessagingTemplate jmsMessagingTemplate; @Autowired() @Qualifier("queue2") private Queue queue2; @Autowired() @Qualifier("queue1") private Queue queue1; @GetMapping("/queue2") public void sendMessage1(String message){ jmsMessagingTemplate.convertAndSend(queue2,"I'm from queue2:"+message); } @GetMapping("/queue1") public void sendMessage2(String message){ jmsMessagingTemplate.convertAndSend(queue1,"I'm from queue1:"+message); } }

上面的类创建了两个GET接口，访问这两个接口分别向queue1和queue2中发送消息。