MQ服务注册提示信息调整

ibzdst-core/src/main/java/cn/ibizlab/core/util/config/MQConsumerConfigure.java

@@ -26,8 +26,6 @@ public class MQConsumerConfigure {
     private String resultsGroupName;
     @Value("${rocketmq.consumer.namesrvAddr:}")
     private String namesrvAddr;
-    @Value("${rocketmq.consumer.topics:}")
-    private String topics;
     // 消费者线程数据量
     @Value("${rocketmq.consumer.consumeThreadMin:10}")
     private Integer consumeThreadMin;
@@ -53,7 +51,7 @@ public class MQConsumerConfigure {
     @Bean
     @ConditionalOnExpression("${rocketmq.consumer.enabled:false}")
     public DefaultMQPushConsumer defaultConsumer() throws MQClientException {
-        log.info("defaultConsumer 正在创建---------------------------------------");
+        log.info("ruleEngineConsumer 正在创建---------------------------------------");
         DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(ruleEngineGroupName);
         consumer.setNamesrvAddr(namesrvAddr);
         consumer.setConsumeThreadMin(1);
@@ -66,9 +64,9 @@ public class MQConsumerConfigure {
         try {
             consumer.subscribe(ruleEngineTopic, "*");
             consumer.start();
-            log.info("consumer 创建成功 groupName={}, topics={}, namesrvAddr={}",ruleEngineGroupName,topics,namesrvAddr);
+            log.info("ruleEngineConsumer 创建成功 groupName={}, topics={}, namesrvAddr={}",ruleEngineGroupName,ruleEngineTopic,namesrvAddr);
         } catch (MQClientException e) {
-            log.error("consumer 创建失败!");
+            log.error("ruleEngineConsumer 创建失败!");
         }
         return consumer;
     }
@@ -89,9 +87,9 @@ public class MQConsumerConfigure {
             // 设置该消费者订阅的主题和tag，如果订阅该主题下的所有tag，则使用*,
             consumer.subscribe(resultsTopic, "*");
             consumer.start();
-            log.info("consumer 创建成功 groupName={}, topics={}, namesrvAddr={}",resultsGroupName,topics,namesrvAddr);
+            log.info("resultsMQMsgConsumer 创建成功 groupName={}, topics={}, namesrvAddr={}",resultsGroupName,resultsTopic,namesrvAddr);
         } catch (MQClientException e) {
-            log.error("consumer 创建失败!");
+            log.error("resultsMQMsgConsumer 创建失败!");
         }
         return consumer;
     }

ibzdst-core/src/main/java/cn/ibizlab/core/util/config/MQProducerConfigure.java

@@ -45,7 +45,7 @@ public class MQProducerConfigure {
         producer.setSendMsgTimeout(sendMsgTimeOut);
         producer.setRetryTimesWhenSendAsyncFailed(retryTimesWhenSendFailed);
         producer.start();
-        log.info("rocketmq producer server 开启成功----------------------------------");
+        log.info("defaultProducer server 开启成功 groupName={}, namesrvAddr={}",groupName,namesrvAddr);
         return producer;
     }
 }