File tree Expand file tree Collapse file tree 2 files changed +6
-10
lines changed
spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/mongo Expand file tree Collapse file tree 2 files changed +6
-10
lines changed Original file line number Diff line number Diff line change 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 .MultiThreadIoEventLoopGroup ;
25
+ import io .netty .channel .nio .NioIoHandler ;
25
26
import io .netty .channel .socket .SocketChannel ;
26
27
import reactor .core .publisher .Flux ;
27
28
@@ -86,7 +87,7 @@ StandardMongoClientSettingsBuilderCustomizer standardMongoSettingsCustomizer(Mon
86
87
}
87
88
88
89
@ Configuration (proxyBeanMethods = false )
89
- @ ConditionalOnClass ({ SocketChannel .class , NioEventLoopGroup .class })
90
+ @ ConditionalOnClass ({ SocketChannel .class , NioIoHandler .class })
90
91
static class NettyDriverConfiguration {
91
92
92
93
@ Bean
@@ -115,9 +116,8 @@ static final class NettyDriverMongoClientSettingsBuilderCustomizer
115
116
@ Override
116
117
public void customize (Builder builder ) {
117
118
if (!isCustomTransportConfiguration (this .settings .getIfAvailable ())) {
118
- NioEventLoopGroup eventLoopGroup = new NioEventLoopGroup ();
119
- this .eventLoopGroup = eventLoopGroup ;
120
- builder .transportSettings (TransportSettings .nettyBuilder ().eventLoopGroup (eventLoopGroup ).build ());
119
+ this .eventLoopGroup = new MultiThreadIoEventLoopGroup (NioIoHandler .newFactory ());
120
+ builder .transportSettings (TransportSettings .nettyBuilder ().eventLoopGroup (this .eventLoopGroup ).build ());
121
121
}
122
122
}
123
123
Original file line number Diff line number Diff line change @@ -1634,17 +1634,13 @@ bom {
1634
1634
releaseNotes(" https://github.com/neo4j/neo4j-java-driver/releases/tag/{version}" )
1635
1635
}
1636
1636
}
1637
- library(" Netty" , " 4.1.122 .Final" ) {
1637
+ library(" Netty" , " 4.2.2 .Final" ) {
1638
1638
prohibit {
1639
1639
contains " .Alpha"
1640
1640
contains " .Beta"
1641
1641
contains " .RC"
1642
1642
because " we don't want alphas, betas, or release candidates"
1643
1643
}
1644
- prohibit {
1645
- versionRange " [4.2.0,)"
1646
- because " Reactor Netty will not support it in time for 3.5.x"
1647
- }
1648
1644
group(" io.netty" ) {
1649
1645
bom(" netty-bom" )
1650
1646
}
You can’t perform that action at this time.
0 commit comments