diff --git 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 index aa31be3f..257f56ce 100644 --- 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(), diff --git 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 index c5d65dec..1fd8fa1f 100644 --- 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 {