diff --git a/ms-biz/src/main/java/com/ms/biz/paas/MqDemoService.java b/ms-biz/src/main/java/com/ms/biz/paas/MqDemoService.java index f33e763..58a0062 100644 --- a/ms-biz/src/main/java/com/ms/biz/paas/MqDemoService.java +++ b/ms-biz/src/main/java/com/ms/biz/paas/MqDemoService.java @@ -15,6 +15,7 @@ import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.remoting.common.RemotingHelper; import org.springframework.context.ApplicationListener; import org.springframework.context.event.ContextRefreshedEvent; +import org.springframework.stereotype.Component; import java.util.List; @@ -24,10 +25,10 @@ import java.util.List; * date 2022/11/24 5:14 PM */ @Slf4j -//@Component +@Component public class MqDemoService implements ApplicationListener { - private static final String TOPIC = MqFactory.generateProdTopic("order_status_changed"); - private static final String GROUP = "GID_payment"; + private static final String TOPIC = MqFactory.generateProdTopic("miaoshougoods_test"); + private static final String GROUP = "GID_miaoshougoods_test"; public void testSendMsg() { DefaultMQProducer producer; diff --git a/pom.xml b/pom.xml index 87792a3..90cf535 100644 --- a/pom.xml +++ b/pom.xml @@ -6,7 +6,7 @@ com.jinritemai.cloud base-parent - 0.3.1-RELEASE + 0.3.6-RELEASE