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

device-manager/src/main/java/com/mortals/xhx/common/utils/DownMsgTask.java

@@ -73,8 +73,8 @@ public class DownMsgTask implements Runnable {
 
                         CorrelationData correlationData = new CorrelationData();
                         correlationData.setId(deviceEntity.getDeviceCode());
-
-                        messageProducer.sendMsg(QueueKey.DEFAULT_EXCHANGE, Constant.DOWN_TOPIC + deviceEntity.getDeviceCode(), JSON.toJSONString(queueMsg));
+                        log.info("send rabbitmq msg:{}", item.getDeviceCode());
+                        messageProducer.sendMsg(QueueKey.DEFAULT_EXCHANGE, Constant.DOWN_TOPIC + deviceEntity.getDeviceCode(), JSON.toJSONString(queueMsg),correlationData);
 
                         DeviceLogEntity deviceLogEntity = new DeviceLogEntity();
                         deviceLogEntity.initAttrValue();