From eeccd99321fe6cc9ae490fecd734051ead87eeaa Mon Sep 17 00:00:00 2001 From: zhouxiang Date: Fri, 10 Jun 2022 11:16:23 +0800 Subject: [PATCH] [ISSUE #3949] Add port for GrpcServerBuilder --- .../org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java index e380db3439..024766bf48 100644 --- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java +++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java @@ -52,12 +52,11 @@ public class GrpcServerBuilder { private static final InternalLogger log = InternalLoggerFactory.getLogger(LoggerName.PROXY_LOGGER_NAME); protected NettyServerBuilder serverBuilder; - public static GrpcServerBuilder newBuilder(ThreadPoolExecutor executor) { - return new GrpcServerBuilder(executor); + public static GrpcServerBuilder newBuilder(ThreadPoolExecutor executor, int port) { + return new GrpcServerBuilder(executor, port); } - public GrpcServerBuilder(ThreadPoolExecutor executor) { - int port = ConfigurationManager.getProxyConfig().getGrpcServerPort(); + protected GrpcServerBuilder(ThreadPoolExecutor executor, int port) { serverBuilder = NettyServerBuilder.forPort(port); try {