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

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

@@ -86,13 +86,11 @@ public class RabbitConfig {
             public void confirm(CorrelationData correlationData, boolean ack, String cause) {
                 // 发送消息的时候发送的业务id
                 log.info("发送消息id:{},ack:{}",correlationData.getId(),ack);
-                // 时候发送成功，即ACK
-                //log.info(ack);
-                // 发送失败的原因
-              //  System.out.println(cause);
             }
         });
 
+        rabbitTemplate.setReturnCallback(messageCallbackService);
+
 /*        rabbitTemplate.setReturnCallback(messageCallbackService);
 
         rabbitTemplate.setConfirmCallback(messageCallbackService);*/