|
21 | 21 | import com.mongodb.connection.TransportSettings;
|
22 | 22 | import com.mongodb.reactivestreams.client.MongoClient;
|
23 | 23 | import io.netty.channel.EventLoopGroup;
|
24 |
| -import io.netty.channel.nio.NioEventLoopGroup; |
| 24 | +import io.netty.channel.IoHandlerFactory; |
| 25 | +import io.netty.channel.MultiThreadIoEventLoopGroup; |
| 26 | +import io.netty.channel.nio.NioIoHandler; |
25 | 27 | import io.netty.channel.socket.SocketChannel;
|
26 | 28 | import reactor.core.publisher.Flux;
|
27 | 29 |
|
@@ -86,7 +88,7 @@ StandardMongoClientSettingsBuilderCustomizer standardMongoSettingsCustomizer(Mon
|
86 | 88 | }
|
87 | 89 |
|
88 | 90 | @Configuration(proxyBeanMethods = false)
|
89 |
| - @ConditionalOnClass({ SocketChannel.class, NioEventLoopGroup.class }) |
| 91 | + @ConditionalOnClass({ SocketChannel.class, MultiThreadIoEventLoopGroup.class }) |
90 | 92 | static class NettyDriverConfiguration {
|
91 | 93 |
|
92 | 94 | @Bean
|
@@ -115,7 +117,8 @@ static final class NettyDriverMongoClientSettingsBuilderCustomizer
|
115 | 117 | @Override
|
116 | 118 | public void customize(Builder builder) {
|
117 | 119 | if (!isCustomTransportConfiguration(this.settings.getIfAvailable())) {
|
118 |
| - NioEventLoopGroup eventLoopGroup = new NioEventLoopGroup(); |
| 120 | + IoHandlerFactory ioHandlerFactory = NioIoHandler.newFactory(); |
| 121 | + MultiThreadIoEventLoopGroup eventLoopGroup = new MultiThreadIoEventLoopGroup(ioHandlerFactory); |
119 | 122 | this.eventLoopGroup = eventLoopGroup;
|
120 | 123 | builder.transportSettings(TransportSettings.nettyBuilder().eventLoopGroup(eventLoopGroup).build());
|
121 | 124 | }
|
|
0 commit comments