From 7257add69bdd474444416e527b16a086ebc7adc7 Mon Sep 17 00:00:00 2001 From: "kaiyi.lk" Date: Wed, 30 Mar 2022 14:24:37 +0800 Subject: [PATCH] [ISSUE #3949] test cases --- .../java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java | 2 ++ .../apache/rocketmq/proxy/connector/ForwardReadConsumer.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java b/proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java index 6b9ea2cf7e..4cca5a3aec 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java @@ -18,4 +18,6 @@ package org.apache.rocketmq.proxy.common.utils; public class ProxyUtils { public static final int MAX_MSG_NUMS_FOR_POP_REQUEST = 32; + + public static final long MAX_CONSUMER_TIMEOUT_MILLIS = Duration.ofSeconds(20).toMillis(); } diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/connector/ForwardReadConsumer.java b/proxy/src/main/java/org/apache/rocketmq/proxy/connector/ForwardReadConsumer.java index 1cb9da3a6b..f9bf870321 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/connector/ForwardReadConsumer.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/connector/ForwardReadConsumer.java @@ -61,7 +61,7 @@ public class ForwardReadConsumer extends AbstractForwardClient { } public CompletableFuture pullMessage(String address, PullMessageRequestHeader requestHeader) { - return this.pullMessage(address, requestHeader, DEFAULT_MQ_CLIENT_TIMEOUT); + return this.pullMessage(address, requestHeader, ProxyUtils.MAX_CONSUMER_TIMEOUT_MILLIS); } public CompletableFuture pullMessage(String address, PullMessageRequestHeader requestHeader,