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 2012/11/11 15:00:02 UTC
svn commit: r1407989 - in /camel/branches/camel-2.10.x: ./
camel-core/src/test/java/org/apache/camel/processor/SamplingThrottlerTest.java
Author: davsclaus
Date: Sun Nov 11 14:00:01 2012
New Revision: 1407989
URL: http://svn.apache.org/viewvc?rev=1407989&view=rev
Log:
Fixed test
Modified:
camel/branches/camel-2.10.x/ (props changed)
camel/branches/camel-2.10.x/camel-core/src/test/java/org/apache/camel/processor/SamplingThrottlerTest.java
Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Merged /camel/trunk:r1407987
Propchange: camel/branches/camel-2.10.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: camel/branches/camel-2.10.x/camel-core/src/test/java/org/apache/camel/processor/SamplingThrottlerTest.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.10.x/camel-core/src/test/java/org/apache/camel/processor/SamplingThrottlerTest.java?rev=1407989&r1=1407988&r2=1407989&view=diff
==============================================================================
--- camel/branches/camel-2.10.x/camel-core/src/test/java/org/apache/camel/processor/SamplingThrottlerTest.java (original)
+++ camel/branches/camel-2.10.x/camel-core/src/test/java/org/apache/camel/processor/SamplingThrottlerTest.java Sun Nov 11 14:00:01 2012
@@ -37,7 +37,7 @@ public class SamplingThrottlerTest exten
public void testSamplingFromExchangeStream() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMessageCount(2);
+ mock.expectedMinimumMessageCount(2);
mock.setResultWaitTime(3000);
List<Exchange> sentExchanges = new ArrayList<Exchange>();
@@ -49,7 +49,7 @@ public class SamplingThrottlerTest exten
public void testBurstySampling() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMessageCount(2);
+ mock.expectedMinimumMessageCount(2);
mock.setResultWaitTime(3000);
List<Exchange> sentExchanges = new ArrayList<Exchange>();
@@ -67,7 +67,7 @@ public class SamplingThrottlerTest exten
public void testSendLotsOfMessagesSimultaneouslyButOnly3GetThrough() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMessageCount(3);
+ mock.expectedMinimumMessageCount(3);
mock.setResultWaitTime(4000);
final List<Exchange> sentExchanges = Collections.synchronizedList(new ArrayList<Exchange>());
@@ -91,7 +91,7 @@ public class SamplingThrottlerTest exten
public void testSamplingUsingmessageFrequency() throws Exception {
long totalMessages = 100;
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMessageCount(10);
+ mock.expectedMinimumMessageCount(10);
mock.setResultWaitTime(100);
for (int i = 0; i < totalMessages; i++) {
@@ -104,7 +104,7 @@ public class SamplingThrottlerTest exten
public void testSamplingUsingmessageFrequencyViaDSL() throws Exception {
long totalMessages = 50;
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMessageCount(10);
+ mock.expectedMinimumMessageCount(10);
mock.setResultWaitTime(100);
for (int i = 0; i < totalMessages; i++) {