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

[ISSUE #3949] Add port for GrpcServerBuilder

Browse Source
This commit is contained in:
zhouxiang
2022-07-13 11:30:54 +08:00
parent 042febd9f1
commit eeccd99321
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java
+3 -4
View File
@@ -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 {