camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [08/18] git commit: Fixed test
Date Mon, 24 Feb 2014 16:04:50 GMT
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 <davsclaus@apache.org>
Authored: Mon Feb 24 16:53:39 2014 +0100
Committer: Claus Ibsen <davsclaus@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);


Mime
View raw message