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

proxy some optimization (#6175)

Browse Source 
Co-authored-by: loboxu <loboxu@tencent.com>
This commit is contained in:
Lobo Xu
2023-02-27 13:59:29 +08:00
committed by GitHub
co-authored by loboxu
parent 90bf886340
commit ed849142f5
2 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
+3 -2
View File
@@ -18,6 +18,7 @@
package org.apache.rocketmq.proxy.grpc;
import java.util.concurrent.TimeUnit;
import io.grpc.Server;
import org.apache.rocketmq.common.constant.LoggerName;
import org.apache.rocketmq.logging.org.slf4j.Logger;
import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
@@ -26,9 +27,9 @@ import org.apache.rocketmq.proxy.common.StartAndShutdown;
public class GrpcServer implements StartAndShutdown {
private static final Logger log = LoggerFactory.getLogger(LoggerName.PROXY_LOGGER_NAME);
private final io.grpc.Server server;
private final Server server;
protected GrpcServer(io.grpc.Server server) {
protected GrpcServer(Server server) {
this.server = server;
}
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
+2 -1
View File
@@ -50,12 +50,13 @@ public class GrpcChannelManager implements StartAndShutdown {
public GrpcChannelManager(ProxyRelayService proxyRelayService, GrpcClientSettingsManager grpcClientSettingsManager) {
this.proxyRelayService = proxyRelayService;
this.grpcClientSettingsManager = grpcClientSettingsManager;
this.init();
}
protected void init() {
this.scheduledExecutorService.scheduleAtFixedRate(
this::scanExpireResultFuture,
10, 10, TimeUnit.SECONDS
10, 1, TimeUnit.SECONDS
);
}