test方法

jsowell-common/src/main/java/com/jsowell/common/config/mq/RabbitConfig.java

@@ -1,6 +1,6 @@
 package com.jsowell.common.config.mq;
 
-import org.springframework.amqp.core.AcknowledgeMode;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.config.RetryInterceptorBuilder;
 import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
@@ -28,6 +28,7 @@ import org.springframework.retry.support.RetryTemplate;
 //      #以下是rabbitmqTemplate配置
 //      mandatory: true)
 // 3---设置重试
+@Slf4j
 @Configuration
 public class RabbitConfig {
 
@@ -77,7 +78,7 @@ public class RabbitConfig {
         // 预加载消息数量 -- QOS
         containerFactory.setPrefetchCount(1);
         // 应答模式（此处设置为手动）
-        containerFactory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
+        // containerFactory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
         // 消息序列化方式
         containerFactory.setMessageConverter(new Jackson2JsonMessageConverter());
         // 设置通知调用链 （这里设置的是重试机制的调用链）
@@ -143,7 +144,7 @@ public class RabbitConfig {
             @Override
             public <T, E extends Throwable> void onError(RetryContext retryContext, RetryCallback<T, E> retryCallback, Throwable throwable) {
                 //  异常 都会调用
-                System.err.println("-----第{}次调用"+retryContext.getRetryCount());
+                log.info("-----第{}次调用", retryContext.getRetryCount());
             }
         });
         retryTemplate.setBackOffPolicy(backOffPolicyByProperties());