SpringBoot2.0 整合 RocketMQ ,实现请求异步处理

1621740748 · Sep 14, 2019 · 0170734 · 0170734
1 parent 5398a7e
commit 0170734
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/ware-rocket-queue/src/main/java/com/rocket/queue/rocket/RocketMsgListener.java b/ware-rocket-queue/src/main/java/com/rocket/queue/rocket/RocketMsgListener.java
@@ -34,7 +34,7 @@ public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeCo
         if(messageExt.getTopic().equals(paramConfigService.rocketTopic)){
             String tags = messageExt.getTags() ;
             switch (tags){
-                case "FeeAccountTag":
+                case "rocketTag":
                     LOG.info("开户 tag == >>"+tags);
                     break ;
                 default:

diff --git a/ware-rocket-queue/src/main/java/com/rocket/queue/service/impl/RocketMqServiceImpl.java b/ware-rocket-queue/src/main/java/com/rocket/queue/service/impl/RocketMqServiceImpl.java
@@ -20,7 +20,7 @@ public SendResult openAccountMsg(String msgInfo) {
         try {
             Message sendMsg = new Message(paramConfigService.rocketTopic,
                                           paramConfigService.rocketTag,
-                                         "fee_open_account_key", msgInfo.getBytes());
+                                         "open_account_key", msgInfo.getBytes());
             sendResult = defaultMQProducer.send(sendMsg);
         } catch (Exception e) {
             e.printStackTrace();

diff --git a/ware-rocket-queue/src/main/resources/application-dev.yml b/ware-rocket-queue/src/main/resources/application-dev.yml
@@ -21,7 +21,7 @@ rocketmq:
     # 服务地址
     namesrvAddr: 127.0.0.1:9876
     # 接收该 Topic 下所有 Tag
-    topics: FeePlatTopic~*;
+    topics: CicadaTopic~*;
     consumeThreadMin: 20
     consumeThreadMax: 64
     # 设置一次消费消息的条数，默认为1条