From 0cdfa32ff4ed376959d4a071369c71c92129c5e1 Mon Sep 17 00:00:00 2001 From: wuxicheng <1441859745@qq.com> Date: Thu, 25 May 2023 11:26:34 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../bnyer/common/rocketmq/strategy/RedisRepeatStrategy.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/strategy/RedisRepeatStrategy.java b/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/strategy/RedisRepeatStrategy.java index 1317de6..35b2b23 100644 --- a/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/strategy/RedisRepeatStrategy.java +++ b/bnyer-common/bnyer-common-rocketmq/src/main/java/com/bnyer/common/rocketmq/strategy/RedisRepeatStrategy.java @@ -44,9 +44,9 @@ public class RedisRepeatStrategy implements RepeatConsumerStrategy { private boolean doInvoke(T message) { IPersist persist = repeatConfig.getPersist(); - //RepeatElement repeatElement = new RepeatElement(repeatConfig.getApplicationName(), message.getConsumerGroupName(),message.getTopic() - // , message.getTag()==null ? "" : message.getTag() - // , repeatMessageKeyFunction.apply(message)); + RepeatElement repeatElement = new RepeatElement(repeatConfig.getApplicationName(), message.getConsumerGroupName(),message.getTopic() + , message.getTag()==null ? "" : message.getTag() + , repeatMessageKeyFunction.apply(message)); boolean shouldConsume = true; if (StringUtils.isNotBlank(repeatElement.getMessageKey())) { shouldConsume = persist.setConsumingIfNX(repeatElement, repeatConfig.getProcessingExpireMilliSeconds());