消费者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. 运行