proxy some optimization

apache · Feb 24, 2023 · b12641b · b12641b
1 parent f1eb88e
commit b12641b
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 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
@@ -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 @@
 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
@@ -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
         );
     }