From df4441322e9801c102299451da41d7c40b4502e9 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 24 六月 2021 18:53:13 +0800 Subject: [PATCH] zookeeper地址修改,Maven采用私服 --- service-daylucky/src/main/java/com/ks/daylucky/config/CMQConsumeConfig.java | 9 +++++++++ 1 files changed, 9 insertions(+), 0 deletions(-) diff --git a/service-daylucky/src/main/java/com/ks/daylucky/config/CMQConsumeConfig.java b/service-daylucky/src/main/java/com/ks/daylucky/config/CMQConsumeConfig.java index fdca3ef..8297ddf 100644 --- a/service-daylucky/src/main/java/com/ks/daylucky/config/CMQConsumeConfig.java +++ b/service-daylucky/src/main/java/com/ks/daylucky/config/CMQConsumeConfig.java @@ -1,5 +1,6 @@ package com.ks.daylucky.config; +import com.ks.daylucky.util.mq.consumer.ActivityDrawnNotifyConsumer; import com.ks.daylucky.util.mq.consumer.MsgConsumer; import com.ks.lucky.utils.mq.CMQConsumeRunner; import org.slf4j.Logger; @@ -25,4 +26,12 @@ CMQConsumeRunner runner = new MsgConsumer(); return runner; } + + + @Bean(initMethod = "start", destroyMethod = "destroy") + public CMQConsumeRunner drawnNorifyConsumer() { + //璁㈤槄娲诲姩鐘舵�佹敼鍙樹富棰樹笌鍔╁姏涓婚 + CMQConsumeRunner runner = new ActivityDrawnNotifyConsumer(); + return runner; + } } -- Gitblit v1.8.0