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