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 {