Repository: camel Updated Branches: refs/heads/master 29c2a5211 -> f1cf1397b
CAMEL-6555 clean up the code camel-netty4 Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/661924ad Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/661924ad Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/661924ad Branch: refs/heads/master Commit: 661924ad4eb9386719b49b2495dbaad68271d424 Parents: 29c2a52 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Mon Jul 28 15:42:55 2014 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Mon Jul 28 15:42:55 2014 +0800 ---------------------------------------------------------------------- .../java/org/apache/camel/component/netty4/NettyProducer.java | 3 +-- .../component/netty4/SingleUDPNettyServerBootstrapFactory.java | 1 - .../org/apache/camel/component/netty4/NettyConverterTest.java | 1 - 3 files changed, 1 insertion(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/661924ad/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java index c0e5360..2183f6f 100644 --- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java +++ b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyProducer.java @@ -21,12 +21,10 @@ import java.net.InetSocketAddress; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; -import java.util.concurrent.Executors; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.TimeUnit; import io.netty.bootstrap.Bootstrap; -import io.netty.bootstrap.ChannelFactory; import io.netty.channel.Channel; import io.netty.channel.ChannelFuture; import io.netty.channel.ChannelFutureListener; @@ -40,6 +38,7 @@ import io.netty.channel.socket.nio.NioSocketChannel; import io.netty.util.HashedWheelTimer; import io.netty.util.Timer; import io.netty.util.concurrent.ImmediateEventExecutor; + import org.apache.camel.AsyncCallback; import org.apache.camel.CamelContext; import org.apache.camel.CamelException; http://git-wip-us.apache.org/repos/asf/camel/blob/661924ad/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SingleUDPNettyServerBootstrapFactory.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SingleUDPNettyServerBootstrapFactory.java b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SingleUDPNettyServerBootstrapFactory.java index 935b714..8d42699 100644 --- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SingleUDPNettyServerBootstrapFactory.java +++ b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/SingleUDPNettyServerBootstrapFactory.java @@ -54,7 +54,6 @@ public class SingleUDPNettyServerBootstrapFactory extends ServiceSupport impleme private NettyServerBootstrapConfiguration configuration; private ChannelInitializer<Channel> pipelineFactory; private NetworkInterface multicastNetworkInterface; - private DatagramChannel datagramChannel; private Channel channel; private EventLoopGroup workerGroup; http://git-wip-us.apache.org/repos/asf/camel/blob/661924ad/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConverterTest.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConverterTest.java b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConverterTest.java index 8d856ed..bb4f8a1 100644 --- a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConverterTest.java +++ b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyConverterTest.java @@ -17,7 +17,6 @@ package org.apache.camel.component.netty4; import io.netty.buffer.ByteBuf; -import io.netty.buffer.ByteBufAllocator; import io.netty.buffer.PooledByteBufAllocator; import org.apache.camel.impl.DefaultExchange; import org.apache.camel.test.junit4.CamelTestSupport;