This is an automated email from the ASF dual-hosted git repository. gnodet pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit ea78642395d17d247a7faa96c0d485f17a6d32b4 Author: Guillaume Nodet <gno...@gmail.com> AuthorDate: Tue Mar 23 17:58:19 2021 +0100 Fix CS --- .../netty/NettyUseSharedWorkerThreadPoolManyRoutesTest.java | 2 +- .../camel/component/netty/NettyUseSharedWorkerThreadPoolTest.java | 8 ++++---- .../camel/component/netty/UnsharableCodecsConflictsTest.java | 4 ++-- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolManyRoutesTest.java b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolManyRoutesTest.java index 6c81982..73347fd 100644 --- a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolManyRoutesTest.java +++ b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolManyRoutesTest.java @@ -37,7 +37,7 @@ public class NettyUseSharedWorkerThreadPoolManyRoutesTest extends BaseNettyTest @BindToRegistry("sharedBoss") private EventLoopGroup sharedWorkerGroup = new NettyServerBossPoolBuilder().withBossCount(20).build(); private int before; - protected AvailablePortFinder.Port[] ports; + private AvailablePortFinder.Port[] ports; @Override protected boolean useJmx() { diff --git a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolTest.java b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolTest.java index 8266abc..1cd4441 100644 --- a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolTest.java +++ b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyUseSharedWorkerThreadPoolTest.java @@ -27,16 +27,16 @@ import static org.junit.jupiter.api.Assertions.assertEquals; public class NettyUseSharedWorkerThreadPoolTest extends BaseNettyTest { + @RegisterExtension + protected AvailablePortFinder.Port port2 = AvailablePortFinder.find(); + @RegisterExtension + protected AvailablePortFinder.Port port3 = AvailablePortFinder.find(); @BindToRegistry("sharedServerPool") private EventLoopGroup sharedWorkerServerGroup = new NettyWorkerPoolBuilder().withWorkerCount(2).withName("NettyServer").build(); @BindToRegistry("sharedClientPool") private EventLoopGroup sharedWorkerClientGroup = new NettyWorkerPoolBuilder().withWorkerCount(3).withName("NettyClient").build(); - @RegisterExtension - protected AvailablePortFinder.Port port2 = AvailablePortFinder.find(); - @RegisterExtension - protected AvailablePortFinder.Port port3 = AvailablePortFinder.find(); @Override protected boolean useJmx() { diff --git a/components/camel-netty/src/test/java/org/apache/camel/component/netty/UnsharableCodecsConflictsTest.java b/components/camel-netty/src/test/java/org/apache/camel/component/netty/UnsharableCodecsConflictsTest.java index 884fbae..1455466 100644 --- a/components/camel-netty/src/test/java/org/apache/camel/component/netty/UnsharableCodecsConflictsTest.java +++ b/components/camel-netty/src/test/java/org/apache/camel/component/netty/UnsharableCodecsConflictsTest.java @@ -42,11 +42,11 @@ public class UnsharableCodecsConflictsTest extends BaseNettyTest { private static final Logger LOG = LoggerFactory.getLogger(UnsharableCodecsConflictsTest.class); - private Processor processor = new P(); - @RegisterExtension protected AvailablePortFinder.Port port2 = AvailablePortFinder.find(); + private Processor processor = new P(); + @BindToRegistry("length-decoder") private ChannelHandlerFactory decoder = ChannelHandlerFactories.newLengthFieldBasedFrameDecoder(1048576, 0, 4, 0, 4);