Skip to content

Commit 2d435c4

Browse files
committed
Update Netty API usage
1 parent 3fb4e2f commit 2d435c4

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

spring-grpc-core/src/main/java/org/springframework/grpc/server/NettyGrpcServerFactory.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,8 @@
2323

2424
import io.grpc.TlsServerCredentials.ClientAuth;
2525
import io.grpc.netty.NettyServerBuilder;
26-
import io.netty.channel.epoll.EpollEventLoopGroup;
26+
import io.netty.channel.MultiThreadIoEventLoopGroup;
27+
import io.netty.channel.epoll.EpollIoHandler;
2728
import io.netty.channel.epoll.EpollServerDomainSocketChannel;
2829
import io.netty.channel.unix.DomainSocketAddress;
2930

@@ -49,8 +50,8 @@ protected NettyServerBuilder newServerBuilder() {
4950
String path = address.substring(5);
5051
return NettyServerBuilder.forAddress(new DomainSocketAddress(path))
5152
.channelType(EpollServerDomainSocketChannel.class)
52-
.bossEventLoopGroup(new EpollEventLoopGroup(1))
53-
.workerEventLoopGroup(new EpollEventLoopGroup());
53+
.bossEventLoopGroup(new MultiThreadIoEventLoopGroup(1, EpollIoHandler.newFactory()))
54+
.workerEventLoopGroup(new MultiThreadIoEventLoopGroup(EpollIoHandler.newFactory()));
5455
}
5556
return super.newServerBuilder();
5657
}

0 commit comments

Comments
 (0)