springboot与activeMQ入门(1) (3)

消费者Comsumer.java代码如下:

@Component //将该类注解到Spring 容器中 public class Comsumer { //接受消息队列1消息 @JmsListener(destination = "active.queue1") //监听active.queue1消息队列 public void readActiveQueue11(String message){ System.out.println(1+message); } //接受消息队列1消息 @JmsListener(destination = "active.queue1") public void readActiveQueue12(String message){ System.out.println(2+message); } //接受消息队列2消息 @JmsListener(destination = "active.queue2") public void readActiveQueue21(String message){ System.out.println(1+message); } //接受消息队列2消息 @JmsListener(destination = "active.queue2") public void readActiveQueue22(String message){ System.out.println(2+message); } }

上面的代码定义了4个消费者,每两个消费一个消息队列。

 3. 运行

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/zywdfz.html