获客链接异常事件消费添加工厂配置

src/main/java/com/yaoyaozw/customer/configs/RabbitConfig.java

@@ -5,8 +5,11 @@ import org.springframework.amqp.core.Binding;
 import org.springframework.amqp.core.BindingBuilder;
 import org.springframework.amqp.core.DirectExchange;
 import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
+import org.springframework.amqp.rabbit.connection.ConnectionFactory;
 import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
 import org.springframework.amqp.support.converter.MessageConverter;
+import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 
@@ -24,6 +27,14 @@ public class RabbitConfig {
     public MessageConverter messageConverter(){
         return new Jackson2JsonMessageConverter();
     }*/
+    @Bean("acquisitionExceptionFactory")
+    public SimpleRabbitListenerContainerFactory acquisitionExceptionFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {
+        SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
+        factory.setPrefetchCount(1);
+        factory.setConcurrentConsumers(1);
+        configurer.configure(factory, connectionFactory);
+        return factory;
+    }
 
 
     @Bean

src/main/java/com/yaoyaozw/customer/consumer/AcquisitionConsumer.java

@@ -17,7 +17,7 @@ public class AcquisitionConsumer {
     private AcquisitionExceptionEventPublisher acquisitionExceptionEventPublisher;
 
 
-    @RabbitListener(queues = "ACQUISITION_EXCEPTION")
+    @RabbitListener(queues = "ACQUISITION_EXCEPTION", containerFactory = "acquisitionExceptionFactory")
     public void acquisitionEventConsumer(Channel channel, Message message){
         byte[] body = message.getBody();
         if (body == null) {