在ActiveMQ中的点对点模式中存在多个消费者( 二 ) _消费

< 10; i++) {utils.sendNorMolMessage(destination, text+i);}return new Result("消息已经产生",true);}
监听消费，设置两个监听者
@Componentpublic class ActiveMqListenConfig {@Autowiredprivate ActiveMqUtils util;private Logger logger = LoggerFactory.getLogger(this.getClass());@JmsListener(destination="queueSend")public void recieveTaskMq(String message) {//Destination destination = new ActiveMQQueue("easySend");logger.info("消费者1监听到的消息是："+message+"，并且这条消息已经被消费了");//再次推送消息//util.sendMessage(destination, "监听到消息，给你返回");}@JmsListener(destination="queueSend")public void recieveTaskMq2(String message) {//Destination destination = new ActiveMQQueue("easySend");logger.info("消费者2监听到的消息是："+message+"，并且这条消息已经被消费了");//再次推送消息//util.sendMessage(destination, "监听到消息，给你返回");}}
运行项目后
查看结果
【在ActiveMQ中的点对点模式中存在多个消费者】由结果可以看出，有两个消费者，并且产生的10条消息已经被消费了，从控制台结果可以看出：点对点模式并不是只能有一个消费者，而是一条消息只能有一个消费者消费。