|
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