From 4d92df89fb163b8d899a269da62655927e894958 Mon Sep 17 00:00:00 2001 From: zh_yu Date: Wed, 23 Jan 2019 14:58:52 +0800 Subject: [PATCH] EnableQmq annotation --- qmq-demo/src/main/java/qunar/tc/qmq/demo/config/BeanConfig.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/qmq-demo/src/main/java/qunar/tc/qmq/demo/config/BeanConfig.java b/qmq-demo/src/main/java/qunar/tc/qmq/demo/config/BeanConfig.java index 4f37ef3b..87deb078 100644 --- a/qmq-demo/src/main/java/qunar/tc/qmq/demo/config/BeanConfig.java +++ b/qmq-demo/src/main/java/qunar/tc/qmq/demo/config/BeanConfig.java @@ -20,6 +20,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import qunar.tc.qmq.MessageProducer; +import qunar.tc.qmq.consumer.annotation.EnableQmq; import qunar.tc.qmq.producer.MessageProducerProvider; import java.util.concurrent.LinkedBlockingQueue; @@ -27,6 +28,7 @@ import java.util.concurrent.TimeUnit; @Configuration +@EnableQmq(appCode = "qmq_test", metaServer = "http://127.0.0.1:8080/meta/address") public class BeanConfig { @Bean