This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new c74d329  [ISSUE #656] Set rocketmq-v5-client-spring-boot default 
awaitDuration to 5
c74d329 is described below

commit c74d329b19d3987ae634c4ae52e9e739255e232d
Author: Zhouxiang Zhan <[email protected]>
AuthorDate: Fri May 24 10:26:55 2024 +0800

    [ISSUE #656] Set rocketmq-v5-client-spring-boot default awaitDuration to 5
---
 .../rocketmq/client/annotation/ExtConsumerResetConfiguration.java       | 2 +-
 .../org/apache/rocketmq/client/autoconfigure/RocketMQProperties.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/ExtConsumerResetConfiguration.java
 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/ExtConsumerResetConfiguration.java
index 8615e2b..0bc9564 100644
--- 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/ExtConsumerResetConfiguration.java
+++ 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/annotation/ExtConsumerResetConfiguration.java
@@ -85,6 +85,6 @@ public @interface ExtConsumerResetConfiguration {
     /**
      * The max await time when receive messages from the server.
      */
-    int awaitDuration() default 0;
+    int awaitDuration() default 5;
 
 }
diff --git 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/RocketMQProperties.java
 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/RocketMQProperties.java
index 64c9a6a..18ed9d1 100644
--- 
a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/RocketMQProperties.java
+++ 
b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/autoconfigure/RocketMQProperties.java
@@ -173,7 +173,7 @@ public class RocketMQProperties {
         /**
          * The max await time when receive messages from the server.
          */
-        private int awaitDuration = 0;
+        private int awaitDuration = 5;
 
         /**
          * Tag of consumer.

Reply via email to