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] code refactor

Browse Source
This commit is contained in:
kaiyi.lk
2022-07-13 11:29:16 +08:00
committed by zhouxiang
parent 7257add69b
commit 0bdd9224f6
3 changed files with 2 additions and 3 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,6 +18,4 @@ 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/AbstractForwardClient.java
+1
View File
@@ -23,6 +23,7 @@ import org.apache.rocketmq.proxy.common.StartAndShutdown;
import org.apache.rocketmq.proxy.connector.factory.ForwardClientManager;
public abstract class AbstractForwardClient implements StartAndShutdown {
public static final long MAX_CONSUMER_TIMEOUT_MILLIS = Duration.ofSeconds(20).toMillis();
public static final long DEFAULT_MQ_CLIENT_TIMEOUT = Duration.ofSeconds(3).toMillis();
private final ForwardClientManager clientFactory;
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, ProxyUtils.MAX_CONSUMER_TIMEOUT_MILLIS);
return this.pullMessage(address, requestHeader, MAX_CONSUMER_TIMEOUT_MILLIS);
}
public CompletableFuture<PullResult> pullMessage(String address, PullMessageRequestHeader requestHeader,