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> {