mq抽离 redis抽离

4dkankan-center-scene/src/main/java/com/fdkankan/scene/controller/TestController.java

@@ -160,7 +160,7 @@ public class TestController {
     @GetMapping("/testMQ")
     public SendResult testMQ(){
         SceneVO body = SceneVO.builder().buildType("123").childName("sdfsdfsdf").dataSource("sadfdhgf").id(1213L).build();
-        SendResult sendResult = rocketMQProducer.syncSend("abc", "tag2", UUID.randomUUID().toString(), body, 5000l);
+        SendResult sendResult = rocketMQProducer.syncSend("kkk", "tag2", UUID.randomUUID().toString(), body, 5000l);
         return sendResult;
     }
 

4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/TestMQListener.java

@@ -16,11 +16,11 @@ import org.springframework.stereotype.Component;
  */
 @Slf4j
 @Component
-//@RocketMQMessageListener(
-//        consumerGroup = "${rocketmq.consumer.group}",
-//        topic = "topic_modeling_a_result",
-////        selectorExpression = "${rocketmq.consumer.tags}",
-//        messageModel = MessageModel.BROADCASTING)
+@RocketMQMessageListener(
+        consumerGroup = "lll",
+        topic = "kkk",
+//        selectorExpression = "${rocketmq.consumer.tags}",
+        messageModel = MessageModel.CLUSTERING)
 public class TestMQListener implements RocketMQListener<String> {
 
     @Override