|
60 | 60 | import io.opentelemetry.testing.internal.io.netty.channel.ChannelOption;
|
61 | 61 | import io.opentelemetry.testing.internal.io.netty.channel.ChannelPipeline;
|
62 | 62 | import io.opentelemetry.testing.internal.io.netty.channel.EventLoopGroup;
|
| 63 | +import io.opentelemetry.testing.internal.io.netty.channel.MultiThreadIoEventLoopGroup; |
63 | 64 | import io.opentelemetry.testing.internal.io.netty.channel.SimpleChannelInboundHandler;
|
64 |
| -import io.opentelemetry.testing.internal.io.netty.channel.nio.NioEventLoopGroup; |
| 65 | +import io.opentelemetry.testing.internal.io.netty.channel.nio.NioIoHandler; |
65 | 66 | import io.opentelemetry.testing.internal.io.netty.channel.socket.SocketChannel;
|
66 | 67 | import io.opentelemetry.testing.internal.io.netty.channel.socket.nio.NioSocketChannel;
|
67 | 68 | import io.opentelemetry.testing.internal.io.netty.handler.codec.http.DefaultFullHttpRequest;
|
@@ -453,7 +454,7 @@ void httpPipelining() throws InterruptedException {
|
453 | 454 | TextMapSetter<DefaultFullHttpRequest> setter =
|
454 | 455 | (request, key, value) -> request.headers().set(key, value);
|
455 | 456 |
|
456 |
| - EventLoopGroup eventLoopGroup = new NioEventLoopGroup(); |
| 457 | + EventLoopGroup eventLoopGroup = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory()); |
457 | 458 | try {
|
458 | 459 | Bootstrap bootstrap = buildBootstrap(eventLoopGroup);
|
459 | 460 | Channel channel = bootstrap.connect(address.getHost(), port).sync().channel();
|
@@ -513,7 +514,7 @@ void requestWithNonStandardHttpMethod() throws InterruptedException {
|
513 | 514 | // test uses http 1.1
|
514 | 515 | assumeFalse(options.useHttp2);
|
515 | 516 |
|
516 |
| - EventLoopGroup eventLoopGroup = new NioEventLoopGroup(); |
| 517 | + EventLoopGroup eventLoopGroup = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory()); |
517 | 518 | try {
|
518 | 519 | Bootstrap bootstrap = buildBootstrap(eventLoopGroup);
|
519 | 520 | Channel channel = bootstrap.connect(address.getHost(), port).sync().channel();
|
|
0 commit comments