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.