手动消费

yzg-util-mq/src/main/java/com/yanzuoguang/mq/base/MqConsumeDynamic.java

 package com.yanzuoguang.mq.base;
 
 import com.yanzuoguang.mq.base.consumer.ConsumerSimpleMessageListenerContainer;
+import org.springframework.amqp.core.AcknowledgeMode;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.rabbit.core.ChannelAwareMessageListener;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
@@ -25,6 +26,7 @@ public class MqConsumeDynamic {
     public SimpleMessageListenerContainer init(String queueName, ChannelAwareMessageListener messageListener) {
         ConsumerSimpleMessageListenerContainer container = new ConsumerSimpleMessageListenerContainer();
         container.setConnectionFactory(connectionFactory);
+        container.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         container.setQueueNames(queueName);
         container.setConcurrentConsumers(onOfConsumer);
         container.setMessageListener(new MessageListenerAdapter(messageListener));