@@ -70,7 +70,7 @@ public class DynamicRabbitMq {
container.setQueueNames(queueName);
log.info("动态添加mq监听成功,交换机:{},路由key:{},队列:{}", DRIECT_EXCHANGE, routingKey, queueName);
}
- container.setPrefetchCount(100);
+ container.setPrefetchCount(2);
container.setAcknowledgeMode(AcknowledgeMode.MANUAL);//消费者需手动确认
container.setConsumersPerQueue(1);
container.setMessageListener(consumerHandler);