Repository: camel Updated Branches: refs/heads/master 93117a1b2 -> 4e7ec8f79
CAMEL-8350 fixed the NettyUdpConnectedSendTest Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/4e7ec8f7 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/4e7ec8f7 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/4e7ec8f7 Branch: refs/heads/master Commit: 4e7ec8f79b6f4cfc92e41e9f976b1c6fa4d8fcae Parents: 93117a1 Author: Willem Jiang <willem.ji...@gmail.com> Authored: Wed Mar 4 10:02:40 2015 +0800 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Wed Mar 4 10:02:40 2015 +0800 ---------------------------------------------------------------------- .../netty4/NettyUdpConnectedSendTest.java | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/4e7ec8f7/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyUdpConnectedSendTest.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyUdpConnectedSendTest.java b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyUdpConnectedSendTest.java index 579e46b..e876404 100644 --- a/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyUdpConnectedSendTest.java +++ b/components/camel-netty4/src/test/java/org/apache/camel/component/netty4/NettyUdpConnectedSendTest.java @@ -30,17 +30,20 @@ import io.netty.channel.socket.DatagramPacket; import io.netty.channel.socket.nio.NioDatagramChannel; import io.netty.handler.codec.MessageToMessageDecoder; import io.netty.util.CharsetUtil; - import org.apache.camel.builder.RouteBuilder; +import org.junit.FixMethodOrder; import org.junit.Test; +import org.junit.runners.MethodSorters; - +//We need to run the tests with fix order +@FixMethodOrder(MethodSorters.NAME_ASCENDING) public class NettyUdpConnectedSendTest extends BaseNettyTest { private static final String SEND_STRING = "***<We all love camel>***"; private static final int SEND_COUNT = 20; private volatile int receivedCount; private EventLoopGroup group; private Bootstrap bootstrap; + private Channel serverChannel; public void createNettyUdpReceiver() { group = new NioEventLoopGroup(); @@ -58,15 +61,17 @@ public class NettyUdpConnectedSendTest extends BaseNettyTest { public void bind() { - bootstrap.bind().syncUninterruptibly(); + serverChannel = bootstrap.bind().syncUninterruptibly().channel(); } public void stop() { - group.shutdownGracefully(); + // Just make sure we shutdown the listener after the call + serverChannel.close().syncUninterruptibly(); + group.shutdownGracefully().syncUninterruptibly(); } @Test - public void sendConnectedUdp() throws Exception { + public void sendConnectedUdpWithServer() throws Exception { createNettyUdpReceiver(); bind(); for (int i = 0; i < SEND_COUNT; ++i) { @@ -77,7 +82,7 @@ public class NettyUdpConnectedSendTest extends BaseNettyTest { } @Test - public void sendConnectedWithoutReceiver() throws Exception { + public void sendBodyWithoutReceiver() throws Exception { int exceptionCount = 0; for (int i = 0; i < SEND_COUNT; ++i) { try {
