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 <[email protected]>
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".

Reply via email to