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".