From 6786eca24647a1fbd7519e9c9f8432d529bff854 Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Fri, 8 Nov 2024 09:45:41 +0800
Subject: [PATCH] =?UTF-8?q?fix=20-=20=E8=B0=83=E6=95=B4=E7=BB=93=E6=9E=84?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mq => mq/outside}/DingtalkRocketConfiguration.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
 rename workflow-engine-server/src/main/java/cn/axzo/workflow/server/{outside/mq => mq/outside}/DingtalkRocketConfiguration.java (97%)

diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/outside/mq/DingtalkRocketConfiguration.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java
similarity index 97%
rename from workflow-engine-server/src/main/java/cn/axzo/workflow/server/outside/mq/DingtalkRocketConfiguration.java
rename to workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java
index 77292d54f..6b3f4591d 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/outside/mq/DingtalkRocketConfiguration.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/outside/DingtalkRocketConfiguration.java
@@ -1,4 +1,4 @@
-package cn.axzo.workflow.server.outside.mq;
+package cn.axzo.workflow.server.mq.outside;
 
 import cn.axzo.framework.rocketmq.BaseListener;
 import cn.axzo.framework.rocketmq.EventConsumer;
@@ -65,7 +65,7 @@ public class DingtalkRocketConfiguration {
             consumeMode = ConsumeMode.CONCURRENTLY,
             selectorType = SelectorType.TAG,
             selectorExpression = "riven-dingtalk-receive",
-            maxReconsumeTimes = 0,
+            maxReconsumeTimes = 3,
             nameServer = "${rocketmq.name-server}"
     )
     public static class ReplyMessageRocketConsumer extends BaseListener implements RocketMQListener<MessageExt> {