svn commit: r702560 - /activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r702560 - /activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java

davsclaus-2
Author: davsclaus
Date: Tue Oct  7 10:51:15 2008
New Revision: 702560

URL: http://svn.apache.org/viewvc?rev=702560&view=rev
Log:
fixed unit test on Bamboo

Modified:
    activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java

Modified: activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java?rev=702560&r1=702559&r2=702560&view=diff
==============================================================================
--- activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java (original)
+++ activemq/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/aggregator/AggregatorBatchOptionsTest.java Tue Oct  7 10:51:15 2008
@@ -23,8 +23,8 @@
                     // as we have not configured more on the aggregator it will default to aggregate the
                     // latest exchange only
                     .aggregator().header("id")
-                    // wait for 2 seconds to aggregate
-                    .batchTimeout(2000L)
+                    // wait for 0.5 seconds to aggregate
+                    .batchTimeout(500L)
                     // batch size in is the limit of number of exchanges recieved, so when we have received 100
                     // exchanges then whatever we have in the collection will be sent
                     .batchSize(100)
@@ -41,7 +41,7 @@
         MockEndpoint result = getMockEndpoint("mock:result");
 
         // we expect 3 messages grouped by the latest message only
-        result.expectedMessageCount(3);
+        result.expectedMinimumMessageCount(3);
         result.expectedBodiesReceived("Message 1c", "Message 2b", "Message 3a");
 
         // then we sent all the message at once
@@ -72,8 +72,8 @@
                     // as we have not configured more on the aggregator it will default to aggregate the
                     // latest exchange only
                     .aggregator().header("id")
-                    // wait for 2 seconds to aggregate
-                    .batchTimeout(2000L)
+                    // wait for 0.5 seconds to aggregate
+                    .batchTimeout(500L)
                     // batch size in is the limit of number of exchanges recieved, so when we have received 100
                     // exchanges then whatever we have in the collection will be sent
                     .batchSize(5)
@@ -87,7 +87,7 @@
         MockEndpoint result = getMockEndpoint("mock:result");
 
         // we expect 3 messages grouped by the latest message only
-        result.expectedMessageCount(2);
+        result.expectedMinimumMessageCount(2);
         result.expectedBodiesReceived("Message 1c", "Message 2b");
 
         // then we sent all the message at once
@@ -130,7 +130,7 @@
         MockEndpoint result = getMockEndpoint("mock:result");
 
         // we expect 3 messages grouped by the latest message only
-        result.expectedMessageCount(3);
+        result.expectedMinimumMessageCount(3);
         result.expectedBodiesReceived("Message 1c", "Message 2b", "Message 3a");
 
         // then we sent all the message at once