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