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