zhouweidong 发布系统代码 [ibiz-uaa，UAA鉴权]

ibzuaa-core/src/main/java/cn/ibizlab/core/util/config/RocketMQConsumer.java

@@ -14,16 +14,18 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
 
 @Slf4j
 @Configuration
-@ConditionalOnExpression("${rocketmq.isOnOff:'off'}.equals('on')")
+@ConditionalOnExpression("${rocketmq.consumer.isOnOff:'off'}.equals('on')")
 public class RocketMQConsumer {
 
     @Value("${rocketmq.producer.groupName:default}")
     private String groupName;
 
+    @Value("${rocketmq.topic:default}")
+    private String topic;
+
     @Value("${rocketmq.producer.namesrvAddr:127.0.0.1:9876}")
     private String namesrvAddr;
 
-    // 消费者线程数据量
     @Value("${rocketmq.consumer.consumeThreadMin:1}")
     private Integer consumeThreadMin;
 
@@ -33,9 +35,6 @@ public class RocketMQConsumer {
     @Value("${rocketmq.consumer.consumeMessageBatchMaxSize:1}")
     private Integer consumeMessageBatchMaxSize;
 
-    @Value("${rocketmq.topic:default}")
-    private String topic;
-
     @Autowired
     @Lazy
     private RocketMQListenerProcessor listenerProcessor;

ibzuaa-core/src/main/java/cn/ibizlab/core/util/config/RocketMQListenerProcessor.java

@@ -18,7 +18,7 @@ import java.util.List;
  */
 @Slf4j
 @Component
-@ConditionalOnExpression("${rocketmq.producer.isOnOff:'off'}.equals('on')")
+@ConditionalOnExpression("${rocketmq.consumer.isOnOff:'off'}.equals('on')")
 public class RocketMQListenerProcessor implements MessageListenerOrderly {
 
     @Autowired