File tree Expand file tree Collapse file tree 2 files changed +8
-4
lines changed
rabbitmq_stream_management/test/http_SUITE_data/src/test/java/com/rabbitmq/stream
rabbitmq_stream/test/rabbit_stream_SUITE_data/src/test/java/com/rabbitmq/stream Expand file tree Collapse file tree 2 files changed +8
-4
lines changed Original file line number Diff line number Diff line change 25
25
import com .rabbitmq .stream .impl .Client ;
26
26
import com .rabbitmq .stream .impl .Client .Response ;
27
27
import io .netty .channel .EventLoopGroup ;
28
- import io .netty .channel .nio .NioEventLoopGroup ;
28
+ import io .netty .channel .MultiThreadIoEventLoopGroup ;
29
+ import io .netty .channel .nio .NioIoHandler ;
29
30
import java .lang .reflect .Field ;
30
31
import java .lang .reflect .Method ;
31
32
import java .time .Duration ;
@@ -91,7 +92,8 @@ private static EventLoopGroup eventLoopGroup(ExtensionContext context) {
91
92
92
93
@ Override
93
94
public void beforeAll (ExtensionContext context ) {
94
- store (context ).put ("nettyEventLoopGroup" , new NioEventLoopGroup ());
95
+ store (context )
96
+ .put ("nettyEventLoopGroup" , new MultiThreadIoEventLoopGroup (NioIoHandler .newFactory ()));
95
97
}
96
98
97
99
@ Override
Original file line number Diff line number Diff line change 23
23
24
24
import com .rabbitmq .stream .impl .Client ;
25
25
import io .netty .channel .EventLoopGroup ;
26
- import io .netty .channel .nio .NioEventLoopGroup ;
26
+ import io .netty .channel .MultiThreadIoEventLoopGroup ;
27
+ import io .netty .channel .nio .NioIoHandler ;
27
28
import java .lang .reflect .Field ;
28
29
import java .lang .reflect .Method ;
29
30
import java .security .cert .X509Certificate ;
@@ -115,7 +116,8 @@ private static EventLoopGroup eventLoopGroup(ExtensionContext context) {
115
116
116
117
@ Override
117
118
public void beforeAll (ExtensionContext context ) {
118
- store (context ).put ("nettyEventLoopGroup" , new NioEventLoopGroup ());
119
+ store (context )
120
+ .put ("nettyEventLoopGroup" , new MultiThreadIoEventLoopGroup (NioIoHandler .newFactory ()));
119
121
}
120
122
121
123
@ Override
You can’t perform that action at this time.
0 commit comments