ConditionalOnProperty

javahongxi · Jan 22, 2019 · 2d3cde6 · 2d3cde6
1 parent 4025c11
commit 2d3cde6
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/...rs-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer3.java b/...rs-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer3.java
@@ -4,15 +4,16 @@
 import org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener;
 import org.apache.rocketmq.spring.starter.core.RocketMQListener;
 import org.hongxi.whatsmars.rocketmq.boot.OrderPaidEvent;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.stereotype.Service;
 
 /**
  * 指定连接某个MQ集群
  */
-
+@ConditionalOnProperty(prefix = "trade.mq", value = {"nameServer"})
 @Slf4j
 @Service
-@RocketMQMessageListener(nameServer = "127.0.0.1:9877", instanceName = "tradeCluster", topic = "test-topic-3", consumerGroup = "my-consumer_test-topic-3")
+@RocketMQMessageListener(nameServer = "${trade.mq.nameServer}", instanceName = "${trade.mq.nameServer}", topic = "test-topic-3", consumerGroup = "my-consumer_test-topic-3")
 public class MyConsumer3 implements RocketMQListener<String> {
     public void onMessage(String message) {
         log.info("received message: " + message);

diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/application.yml b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/application.yml
@@ -2,4 +2,9 @@ spring:
   rocketmq:
     nameServer: 127.0.0.1:9876
     producer:
-      group: boot_producer_group
+      group: boot_producer_group
+
+trade:
+  mq:
+#    nameServer: 127.0.0.1:9877
+    clusterName: tradeCluster