EnableQmq annotation

fankaidev · Jan 23, 2019 · 4d92df8 · 4d92df8
1 parent b6395f6
commit 4d92df8
Showing 1 changed file with 2 additions and 0 deletions.
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
@@ -20,13 +20,15 @@
 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;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 
 @Configuration
+@EnableQmq(appCode = "qmq_test", metaServer = "http://127.0.0.1:8080/meta/address")
 public class BeanConfig {
 
     @Bean