添加MQ服务开关

ibzdst-boot/src/main/resources/application-boot.yml

@@ -29,10 +29,10 @@ spring:
 
 rocketmq:
   producer:
-    isOnOff: on
+    enabled: true
     namesrvAddr: 172.16.170.163:9876
   consumer:
-    isOnOff: on
+    enabled: true
     namesrvAddr: 172.16.170.163:9876
 
 logging:

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

@@ -51,7 +51,7 @@ public class MQConsumerConfigure {
      * @throws MQClientException
      */
     @Bean
-    //@ConditionalOnExpression("${rocketmq.consumer.isOnOff:off}.equals('on')")
+    @ConditionalOnExpression("${rocketmq.consumer.enabled:false}")
     public DefaultMQPushConsumer defaultConsumer() throws MQClientException {
         log.info("defaultConsumer 正在创建---------------------------------------");
         DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(ruleEngineGroupName);
@@ -74,6 +74,7 @@ public class MQConsumerConfigure {
     }
 
     @Bean
+    @ConditionalOnExpression("${rocketmq.consumer.enabled:false}")
     public DefaultMQPushConsumer resultsMQMsgConsumer() throws MQClientException {
         log.info("resultsMQMsgConsumer 正在创建---------------------------------------");
         DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(resultsGroupName);

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

@@ -35,7 +35,7 @@ public class MQProducerConfigure {
      * @throws MQClientException
      */
     @Bean
-    //@ConditionalOnExpression("${rocketmq.producer.isOnOff:off}.equals('on')")
+    @ConditionalOnExpression("${rocketmq.producer.enabled:false}")
     public DefaultMQProducer defaultProducer() throws MQClientException {
         log.info("defaultProducer 正在创建---------------------------------------");
         DefaultMQProducer producer = new DefaultMQProducer(groupName);