Updated Branches: refs/heads/master 5be16341d -> 2368ed213
Polished. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/2368ed21 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/2368ed21 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/2368ed21 Branch: refs/heads/master Commit: 2368ed213f97146cc11c9868abff3be26e9eccdb Parents: 5be1634 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:27:43 2013 +0200 ---------------------------------------------------------------------- .../component/netty/NettyMultipleSimultaneousClientsTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/2368ed21/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
