|
@@ -72,7 +72,7 @@ public class DynamicRabbitMq {
|
|
|
}
|
|
|
|
|
|
container.setPrefetchCount(100);
|
|
|
- container.setAcknowledgeMode(AcknowledgeMode.AUTO);//消费者需手动确认
|
|
|
+ container.setAcknowledgeMode(AcknowledgeMode.MANUAL);//消费者需手动确认
|
|
|
container.setConsumersPerQueue(1);
|
|
|
container.setMessageListener(consumerHandler);
|
|
|
//配置重发机制
|