You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by di...@apache.org on 2020/04/03 12:52:22 UTC
[rocketmq-spring] branch master updated: [ISSUE #241] Make the unit
of consumeTimeout in rocketmq-spring consistent with rocketmq client
This is an automated email from the ASF dual-hosted git repository.
dinglei 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 1464698 [ISSUE #241] Make the unit of consumeTimeout in rocketmq-spring consistent with rocketmq client
1464698 is described below
commit 1464698a8b03d5700d41efe9258c33acf14b8e81
Author: rongtong <ji...@163.com>
AuthorDate: Fri Apr 3 20:52:15 2020 +0800
[ISSUE #241] Make the unit of consumeTimeout in rocketmq-spring consistent with rocketmq client
---
.../apache/rocketmq/spring/annotation/RocketMQMessageListener.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java
index f1c7748..7b7ff9a 100644
--- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java
+++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/annotation/RocketMQMessageListener.java
@@ -76,9 +76,9 @@ public @interface RocketMQMessageListener {
int consumeThreadMax() default 64;
/**
- * Max consumer timeout, default 30s.
+ * Maximum amount of time in minutes a message may block the consuming thread.
*/
- long consumeTimeout() default 30000L;
+ long consumeTimeout() default 15L;
/**
* The property of "access-key".