From 96f5b122d04263efc7ba73cbe735b963fdb5483c Mon Sep 17 00:00:00 2001
From: wuxicheng <1441859745@qq.com>
Date: Sat, 20 May 2023 23:47:38 +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

---
 .../com/bnyer/common/rocketmq/handle/EnhanceMessageHandler.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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<T extends BaseMessage> {
         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();