From b8b05db31076554f819b9d7c01ff85a1d8e5db47 Mon Sep 17 00:00:00 2001 From: wuxicheng <1441859745@qq.com> Date: Sat, 20 May 2023 23:46:43 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9E=E7=8E=B0=E6=9C=AC=E5=9C=B0=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E8=A1=A8=E6=B6=88=E6=81=AF=E8=A1=A5=E5=81=BF=EF=BC=8C?= =?UTF-8?q?=E6=B6=88=E6=81=AF=E5=8E=BB=E9=87=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bnyer/common/rocketmq/handle/EnhanceMessageHandler.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 e249df5..7d5e980 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.deDupMessageKey(message)); + , this.repeatMessageKey(message)); //消费消息，末尾消费失败会删除消费记录，消费成功则更新消费状态 try { long now = System.currentTimeMillis(); @@ -194,7 +194,7 @@ public abstract class EnhanceMessageHandler { */ protected Boolean handleMsgRepeat(final T message) { RepeatConsumerStrategy strategy = new NormalRepeatStrategy(); - Function repeatKeyFunction = baseMessage -> deDupMessageKey(message); + Function repeatKeyFunction = baseMessage -> repeatMessageKey(message); if (repeatConsumerConfig.getRepeatStrategy() == RepeatConsumerConfig.REPEAT_STRATEGY_CONSUME_LATER) { strategy = new RedisRepeatStrategy(repeatConsumerConfig, repeatKeyFunction); } @@ -205,7 +205,7 @@ public abstract class EnhanceMessageHandler { /** * 默认拿消息key 作为去重的标识，子类可复写该方法自定义去重标识 */ - protected String deDupMessageKey(T message) { + protected String repeatMessageKey(T message) { return message.getMessageKey(); }