svn commit: r1407989 - in /camel/branches/camel-2.10.x: ./ camel-core/src/test/java/org/apache/camel/processor/SamplingThrottlerTest.java

[davsclaus]

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++) {