From a7521a83d1c0f30880a304ceaeff7ffd8b81c4a6 Mon Sep 17 00:00:00 2001 From: zhouxiang Date: Thu, 23 May 2024 16:06:06 +0800 Subject: [PATCH] Set default awaitDuration to 5 --- .../client/annotation/ExtConsumerResetConfiguration.java | 2 +- .../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 8615e2b6..0bc95646 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 @@ /** * 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 64c9a6a1..18ed9d16 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 static class SimpleConsumer { /** * The max await time when receive messages from the server. */ - private int awaitDuration = 0; + private int awaitDuration = 5; /** * Tag of consumer.