diff --git a/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java b/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java
index 75d4b8aa33996d5fc178ac11a19153bdfd7c457d..aaa9ade855668ec8b3602866da13e6b4a21de5e2 100644
--- a/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java
+++ b/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqConsumerTemplate.java
@@ -36,9 +36,6 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
     private Channel channel;
     private Connection connection;
 
-    /**
-     * rabbmit璁剧疆
-     */
     private TbRabbitMqSettings rabbitMqSettings;
 
     private volatile Set<String> queues=new HashSet<>();
@@ -91,11 +88,7 @@ public class TbRabbitMqConsumerTemplate<T extends TbQueueMsg> extends AbstractTb
         topicNames.stream().forEach(topic->{
             queues.add(topic);
         });
-
-//        queues = partitions.stream()
-//                .map(TopicPartitionInfo::getFullTopicName)
-//                .collect(Collectors.toSet());
-        log.info("doSubscribe:{},topicNames:{}", JSON.toJSONString(queues), JSON.toJSONString(queues));
+        log.info("doSubscribe:{}", JSON.toJSONString(queues));
     }
 
     @Override
diff --git a/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqProducerTemplate.java b/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqProducerTemplate.java
index 8627c90d90bce4840592abcf0196bd9149aa1231..bd632a65bd4ffae3a839a98368d66325ff8ba2c1 100644
--- a/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqProducerTemplate.java
+++ b/common-lib/src/main/java/com/mortals/xhx/queue/rabbitmq/TbRabbitMqProducerTemplate.java
@@ -84,6 +84,7 @@ public class TbRabbitMqProducerTemplate<T extends TbQueueMsg> implements TbQueue
         try {
             if (!topicIfNotExist) {
                 //topic涓嶅瓨鍦ㄥ垱寤洪€氶亾闃熷垪
+                log.info("queueDeclareAdd==>exchangeName:{} topic:{}",tpi.getExchangeName(),tpi.getTopic());
                 Map<String, Object> args = new HashMap<>();
                 args.put("x-message-ttl", Integer.parseInt(rabbitMqSettings.getMessageTtl()));
                 channel.queueDeclare(tpi.getTopic(), true, false, false, args);