You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2014/02/24 17:04:50 UTC
[08/18] git commit: Fixed test
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 <da...@apache.org>
Authored: Mon Feb 24 16:53:39 2014 +0100
Committer: Claus Ibsen <da...@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);