测试消息队列

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<ContextRefreshedEvent> {
-    private static final String TOPIC = MqFactory.generateProdTopic("order_status_changed");
+    private static final String TOPIC = MqFactory.generateProdTopic("miaoshougoods_test");
-    private static final String GROUP = "GID_payment";
+    private static final String GROUP = "GID_miaoshougoods_test";
 
     public void testSendMsg() {
         DefaultMQProducer producer;

pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.jinritemai.cloud</groupId>
         <artifactId>base-parent</artifactId>
-        <version>0.3.1-RELEASE</version>
+        <version>0.3.6-RELEASE</version>
         <relativePath/> <!-- lookup parent from repository -->
     </parent>