mq参数默认值调整

ibzdst-core/src/main/java/cn/ibizlab/core/aspect/TopicListenerApsect.java

@@ -19,7 +19,7 @@ import org.springframework.util.ObjectUtils;
  */
 @Aspect
 @Component
-@ConditionalOnExpression("${rocketmq.consumer.enabled}&&'${rocketmq.consumer.namesrvAddr:}'!=''")
+@ConditionalOnExpression("${rocketmq.consumer.enabled:false}")
 public class TopicListenerApsect {
   @Autowired
   private TopicListenter topicListenter;

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

@@ -12,7 +12,7 @@ import org.springframework.context.annotation.Configuration;
 
 @Slf4j
 @Configuration
-@ConditionalOnExpression("${rocketmq.producer.enabled}&&'${rocketmq.producer.namesrvAddr:}'!=''")
+@ConditionalOnExpression("${rocketmq.producer.enabled:false}")
 public class MQProducerConfigure {
     public static final Logger LOGGER = LoggerFactory.getLogger(MQProducerConfigure.class);
 
@@ -36,7 +36,6 @@ public class MQProducerConfigure {
      * @throws MQClientException
      */
     @Bean
-    @ConditionalOnExpression("${rocketmq.producer.enabled:false}")
     public DefaultMQProducer defaultProducer() throws MQClientException {
         log.info("defaultProducer 正在创建---------------------------------------");
         DefaultMQProducer producer = new DefaultMQProducer(groupName);

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

@@ -28,7 +28,7 @@ import static cn.ibizlab.core.enums.RuleEnginerParamEnum.*;
 
 @Component
 @Slf4j
-@ConditionalOnExpression("${rocketmq.consumer.enabled}&&'${rocketmq.consumer.namesrvAddr:}'!=''")
+@ConditionalOnExpression("${rocketmq.consumer.enabled:false}")
 public class RocktcermqCustmerRunner implements ApplicationRunner {
     @Autowired
     private RuleEngineMapper ruleEngineMapper;