更新下发消息为线程池发送

device-manager/src/main/java/com/mortals/xhx/base/framework/config/RabbitConfig.java

@@ -23,6 +23,7 @@ import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainer
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.core.annotation.Order;
+import org.springframework.util.ObjectUtils;
 
 @Configuration
 @Order(1)
@@ -84,9 +85,11 @@ public class RabbitConfig {
         rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
             @Override
             public void confirm(CorrelationData correlationData, boolean ack, String cause) {
+                if(!ObjectUtils.isEmpty(correlationData)){
                     // 发送消息的时候发送的业务id
                     log.info("发送消息id:{},ack:{}",correlationData.getId(),ack);
                 }
+            }
         });
 
         rabbitTemplate.setReturnCallback(messageCallbackService);