This is an automated email from the ASF dual-hosted git repository. coheigea pushed a commit to branch camel-2.25.x in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-2.25.x by this push: new fb677f2 Fixing Netty warnings fb677f2 is described below commit fb677f29ba257eca86899f97fc265529ff3e1560 Author: Colm O hEigeartaigh <cohei...@apache.org> AuthorDate: Tue Feb 4 14:56:54 2020 +0100 Fixing Netty warnings --- .../org/apache/camel/component/netty4/NettyConcurrentTest.java | 6 +++--- .../java/org/apache/camel/component/netty4/NettyTCPAsyncTest.java | 5 ----- .../camel/component/netty4/NettyTransferExchangeOptionTest.java | 1 - .../apache/camel/component/netty4/ObjectSerializationTest.java | 8 ++++---- 4 files changed, 7 insertions(+), 13 deletions(-) diff --git a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConcurrentTest.java b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConcurrentTest.java index cb32e41..e4e8ca0 100644 --- a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConcurrentTest.java +++ b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConcurrentTest.java @@ -26,6 +26,9 @@ import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; +import io.netty.channel.ChannelHandler; +import io.netty.handler.codec.serialization.ClassResolvers; + import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.builder.NotifyBuilder; @@ -37,9 +40,6 @@ import org.apache.camel.util.StopWatch; import org.junit.Ignore; import org.junit.Test; -import io.netty.channel.ChannelHandler; -import io.netty.handler.codec.serialization.ClassResolvers; - public class NettyConcurrentTest extends BaseNettyTest { @Test diff --git a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTCPAsyncTest.java b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTCPAsyncTest.java index 9d02a25..52517bb 100644 --- a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTCPAsyncTest.java +++ b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTCPAsyncTest.java @@ -25,16 +25,11 @@ import org.apache.camel.Message; import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.component.netty4.codec.ObjectDecoder; -import org.apache.camel.component.netty4.codec.ObjectEncoder; import org.apache.camel.converter.IOConverter; import org.apache.camel.impl.JndiRegistry; import org.apache.camel.util.IOHelper; import org.junit.Test; -import io.netty.channel.ChannelHandler; -import io.netty.handler.codec.serialization.ClassResolvers; - public class NettyTCPAsyncTest extends BaseNettyTest { @EndpointInject(uri = "mock:result") protected MockEndpoint resultEndpoint; diff --git a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTransferExchangeOptionTest.java b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTransferExchangeOptionTest.java index 0eef6dc..aba0765 100644 --- a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTransferExchangeOptionTest.java +++ b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyTransferExchangeOptionTest.java @@ -17,7 +17,6 @@ package org.apache.camel.component.netty4; import java.nio.charset.Charset; -import java.util.Properties; import org.apache.camel.Endpoint; import org.apache.camel.Exchange; diff --git a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/ObjectSerializationTest.java b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/ObjectSerializationTest.java index 6e07560..f487341 100644 --- a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/ObjectSerializationTest.java +++ b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/ObjectSerializationTest.java @@ -19,6 +19,9 @@ package org.apache.camel.component.netty4; import java.util.Date; import java.util.Properties; +import io.netty.channel.ChannelHandler; +import io.netty.handler.codec.serialization.ClassResolvers; + import org.apache.camel.CamelExecutionException; import org.apache.camel.Exchange; import org.apache.camel.Processor; @@ -30,9 +33,6 @@ import org.apache.camel.test.AvailablePortFinder; import org.junit.BeforeClass; import org.junit.Test; -import io.netty.channel.ChannelHandler; -import io.netty.handler.codec.serialization.ClassResolvers; - /** * Object Serialization is not allowed by default. However it can be enabled by adding specific encoders/decoders. */ @@ -85,7 +85,7 @@ public class ObjectSerializationTest extends BaseNettyTest { return new RouteBuilder() { @Override public void configure() throws Exception { - from("netty4:tcp://localhost:{{port}}?sync=true") + from("netty4:tcp://localhost:{{port}}?sync=true") .process(new Processor() { public void process(Exchange exchange) throws Exception { Object obj = exchange.getIn().getBody();