You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ka...@apache.org on 2023/02/27 05:59:48 UTC
[rocketmq] branch develop updated: proxy some optimization (#6175)
This is an automated email from the ASF dual-hosted git repository.
kaili pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new ed849142f proxy some optimization (#6175)
ed849142f is described below
commit ed849142f590f216e157157b9700f3493ecda8c8
Author: Lobo Xu <31...@qq.com>
AuthorDate: Mon Feb 27 13:59:29 2023 +0800
proxy some optimization (#6175)
Co-authored-by: loboxu <lo...@tencent.com>
---
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java | 5 +++--
.../apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java | 3 ++-
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
index 4e9dfbcfa..66ab71712 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
@@ -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;
}
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
index fb6df2562..799775412 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
@@ -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
);
}