修改消息组件

device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceServiceImpl.java

@@ -99,7 +99,6 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
                 public void onSuccess(TbQueueMsgMetadata metadata) {
                     log.info("队列创建成功,设备编码:{}", entity.getDeviceCode());
                 }
-
                 @Override
                 public void onFailure(Throwable t) {
                     log.error("队列创建失败,设备通道编码:{},{}", entity.getDeviceCode(), t);
@@ -111,6 +110,10 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
             Set<TopicPartitionInfo> partitions = new HashSet<>();
             partitions.add(info);
             consumerService.getMainConsumer().subscribe(partitions);
+
+            //创建下行队列
+            info = TopicPartitionInfo.builder().exchangeName(exchangeName).topic(Constant.DOWN_TOPIC + entity.getDeviceCode()).build();
+            messageService.queueDeclare(info, callback);
         }