Bump Netty to 4.2.0

References #216

Author: acogoluegnes

pom.xml

@@ -48,7 +48,7 @@
     <stream-client.version>0.24.0-SNAPSHOT</stream-client.version>
     <slf4j.version>2.0.17</slf4j.version>
     <logback.version>1.5.18</logback.version>
-    <netty.version>4.1.119.Final</netty.version>
+    <netty.version>4.2.0.Final</netty.version>
     <metrics.version>4.2.30</metrics.version>
     <micrometer.version>1.14.5</micrometer.version>
     <picocli.version>4.7.6</picocli.version>

src/main/java/com/rabbitmq/stream/perf/StreamPerfTest.java

@@ -46,9 +46,10 @@
 import io.netty.buffer.ByteBufAllocatorMetricProvider;
 import io.netty.channel.ChannelOption;
 import io.netty.channel.EventLoopGroup;
-import io.netty.channel.epoll.EpollEventLoopGroup;
+import io.netty.channel.MultiThreadIoEventLoopGroup;
+import io.netty.channel.epoll.EpollIoHandler;
 import io.netty.channel.epoll.EpollSocketChannel;
-import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.nio.NioIoHandler;
 import io.netty.handler.ssl.SslContextBuilder;
 import io.netty.handler.ssl.SslHandler;
 import io.netty.util.internal.PlatformDependent;
@@ -933,10 +934,10 @@ public Integer call() throws Exception {
 
       java.util.function.Consumer<Bootstrap> bootstrapCustomizer;
       if (this.nativeEpoll) {
-        this.eventLoopGroup = new EpollEventLoopGroup();
+        this.eventLoopGroup = new MultiThreadIoEventLoopGroup(EpollIoHandler.newFactory());
         bootstrapCustomizer = b -> b.channel(EpollSocketChannel.class);
       } else {
-        this.eventLoopGroup = new NioEventLoopGroup();
+        this.eventLoopGroup = new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory());
         bootstrapCustomizer = b -> {};
       }
 

src/test/java/com/rabbitmq/stream/perf/TestUtils.java

@@ -21,7 +21,8 @@
 
 import com.rabbitmq.stream.impl.Client;
 import io.netty.channel.EventLoopGroup;
-import io.netty.channel.nio.NioEventLoopGroup;
+import io.netty.channel.MultiThreadIoEventLoopGroup;
+import io.netty.channel.nio.NioIoHandler;
 import java.lang.annotation.*;
 import java.lang.reflect.Field;
 import java.lang.reflect.Method;
@@ -234,7 +235,8 @@ static EventLoopGroup eventLoopGroup(ExtensionContext context) {
 
     @Override
     public void beforeAll(ExtensionContext context) {
-      store(context).put("nettyEventLoopGroup", new NioEventLoopGroup());
+      store(context)
+          .put("nettyEventLoopGroup", new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory()));
     }
 
     @Override