diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer3.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer3.java index 229a31b1..9775c623 100644 --- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/rocketmq/boot/consumer/MyConsumer3.java +++ b/whatsmars-mq/whatsmars-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 { 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 index 290bf665..99458360 100644 --- 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 \ No newline at end of file + group: boot_producer_group + +trade: + mq: +# nameServer: 127.0.0.1:9877 + clusterName: tradeCluster \ No newline at end of file