diff --git a/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/handle/EnhanceMessageHandler.java b/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/handle/EnhanceMessageHandler.java index 7d5e980..2a66e80 100644 --- a/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/handle/EnhanceMessageHandler.java +++ b/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/handle/EnhanceMessageHandler.java @@ -128,7 +128,7 @@ public abstract class EnhanceMessageHandler { IPersist persist = repeatConsumerConfig.getPersist(); RepeatElement repeatElement = new RepeatElement(repeatConsumerConfig.getApplicationName(), message.getConsumerGroupName(),message.getTopic() , message.getTag()==null ? "" : message.getTag() - , this.repeatMessageKey(message)); + , repeatMessageKey(message)); //消费消息,末尾消费失败会删除消费记录,消费成功则更新消费状态 try { long now = System.currentTimeMillis();