Updated Branches: refs/heads/camel-2.11.x b1bfa17af -> e7a040b2c
Polished. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/e7a040b2 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/e7a040b2 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/e7a040b2 Branch: refs/heads/camel-2.11.x Commit: e7a040b2c5468e62c018d92e6953fafade1e1fa8 Parents: b1bfa17 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:29:10 2013 +0200 ---------------------------------------------------------------------- .../component/netty/NettyMultipleSimultaneousClientsTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/e7a040b2/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
