buy_success 修复

2026-01-08 20:25:34 +08:00 · 2026-01-08 20:25:34 +08:00 · 0dd193dc64
commit 0dd193dc64
parent 7ae13bbd43
2 changed files with 3 additions and 3 deletions
--- a/rc-service/rc-service-order/order-application/src/main/java/com/red/circle/order/app/listener/BuySuccessListener.java
+++ b/rc-service/rc-service-order/order-application/src/main/java/com/red/circle/order/app/listener/BuySuccessListener.java
@ -77,7 +77,7 @@ public class BuySuccessListener implements MessageListener {
            .logTag("语音房会话")
            .consumeMsgTimeoutMinute(15)
            .repeatConsumeMinute(15)
-            .repeatConsumeTag(extractOrderNo(message))
+            .repeatConsumeTag("BuySuccess")
            .checkConsumeTag(BuySuccessSink.TAG)
            .message(message)
            .build(),
--- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/BadgeCheckListener.java
+++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/listener/BadgeCheckListener.java
@ -18,8 +18,8 @@ import lombok.extern.slf4j.Slf4j;
 *
 * @author pengliang on 2021/4/8
 */
-@Slf4j
-@RocketMqMessageListener(groupId = BadgeCheckSink.INPUT, tag = BadgeCheckSink.TAG)
+//@Slf4j
+//@RocketMqMessageListener(groupId = BadgeCheckSink.INPUT, tag = BadgeCheckSink.TAG)
@RequiredArgsConstructor
 public class BadgeCheckListener implements MessageListener {