Fixed test
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/90685ddb Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/90685ddb Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/90685ddb Branch: refs/heads/camel-2.12.x Commit: 90685ddb32f3826b47965f4f6cc7698acc918dfd Parents: b381e74 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:42 2014 +0100 ---------------------------------------------------------------------- .../camel/processor/StreamResequencerTest.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/90685ddb/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);