Updated Branches: refs/heads/camel-2.10.x 797fc3d08 -> 8a8cf9e93
Polished. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8a8cf9e9 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8a8cf9e9 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8a8cf9e9 Branch: refs/heads/camel-2.10.x Commit: 8a8cf9e93a13879c725db795aad95f79a2a996ed Parents: 797fc3d Author: Babak Vahdat <bvah...@apache.org> Authored: Thu Aug 15 11:27:43 2013 +0200 Committer: Babak Vahdat <bvah...@apache.org> Committed: Thu Aug 15 11:30:06 2013 +0200 ---------------------------------------------------------------------- .../component/netty/NettyMultipleSimultaneousClientsTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/8a8cf9e9/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyMultipleSimultaneousClientsTest.java ---------------------------------------------------------------------- diff --git a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyMultipleSimultaneousClientsTest.java b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyMultipleSimultaneousClientsTest.java index c55b0a2..65ab5d5 100644 --- a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyMultipleSimultaneousClientsTest.java +++ b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyMultipleSimultaneousClientsTest.java @@ -45,12 +45,12 @@ public class NettyMultipleSimultaneousClientsTest extends BaseNettyTest { replies[i] = executorService.submit(new Callable<Object>() { @Override public Object call() throws Exception { - // wait until we're permitted to start + // wait until we're allowed to start startLatch.await(); Object reply = template.requestBody(uri, "World"); - // signal that we're now done + // signal that we're done now finishLatch.countDown(); return reply; @@ -71,7 +71,6 @@ public class NettyMultipleSimultaneousClientsTest extends BaseNettyTest { // and wait long enough until they're all done assertTrue("Waiting on the latch ended up with a timeout!", finishLatch.await(5, TimeUnit.SECONDS)); - // shutdown the thread pool as the finishLatch above has already guaranteed the completion of all the tasks executorService.shutdown(); // assert on what we expect to receive
