opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-24 16:04:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #3949] test cases

Browse Source
This commit is contained in:
kaiyi.lk
2022-07-13 11:29:16 +08:00
committed by zhouxiang
parent c1d26c8b10
commit 7257add69b
2 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java
+2
View File
@@ -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();
}
proxy/src/main/java/org/apache/rocketmq/proxy/connector/ForwardReadConsumer.java
+1 -1
View File
@@ -61,7 +61,7 @@ public class ForwardReadConsumer extends AbstractForwardClient {
}
public CompletableFuture<PullResult> 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<PullResult> pullMessage(String address, PullMessageRequestHeader requestHeader,