Fixed test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/8ace0ebc Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8ace0ebc Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8ace0ebc Branch: refs/heads/master Commit: 8ace0ebc09287a9d84f008d546ef87ce4eaa7dc0 Parents: 76bc00f Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Feb 24 16:53:39 2014 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Feb 24 17:05:29 2014 +0100 ---------------------------------------------------------------------- .../camel/processor/StreamResequencerTest.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/8ace0ebc/camel-core/src/test/java/org/apache/camel/processor/StreamResequencerTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/processor/StreamResequencerTest.java b/camel-core/src/test/java/org/apache/camel/processor/StreamResequencerTest.java index 8498f1b..7e7f73f 100644 --- a/camel-core/src/test/java/org/apache/camel/processor/StreamResequencerTest.java +++ b/camel-core/src/test/java/org/apache/camel/processor/StreamResequencerTest.java @@ -58,14 +58,6 @@ public class StreamResequencerTest extends ContextTestSupport { public void testMultithreaded() throws Exception { int numMessages = 100; - ProducerTemplate producerTemplate = context.createProducerTemplate(); - ProducerTemplate producerTemplate2 = context.createProducerTemplate(); - - ExecutorService service = context.getExecutorServiceManager().newFixedThreadPool(this, getName(), 2); - - service.execute(new Sender(producerTemplate, 0, numMessages, 2)); - service.execute(new Sender(producerTemplate2, 1, numMessages, 2)); - Object[] bodies = new Object[numMessages]; for (int i = 0; i < numMessages; i++) { bodies[i] = "msg" + i; @@ -74,6 +66,14 @@ public class StreamResequencerTest extends ContextTestSupport { getMockEndpoint("mock:result").expectedBodiesReceived(bodies); getMockEndpoint("mock:result").setResultWaitTime(20000); + ProducerTemplate producerTemplate = context.createProducerTemplate(); + ProducerTemplate producerTemplate2 = context.createProducerTemplate(); + + ExecutorService service = context.getExecutorServiceManager().newFixedThreadPool(this, getName(), 2); + + service.execute(new Sender(producerTemplate, 0, numMessages, 2)); + service.execute(new Sender(producerTemplate2, 1, numMessages, 2)); + assertMockEndpointsSatisfied(); ServiceHelper.stopServices(producerTemplate, producerTemplate2);