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 2009/04/20 08:22:02 UTC
svn commit: r766587 -
/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
Author: davsclaus
Date: Mon Apr 20 06:22:02 2009
New Revision: 766587
URL: http://svn.apache.org/viewvc?rev=766587&view=rev
Log:
Give slower servers a chance to pass, reported by TC. Notice trunk also uses 10 as expected message count.
Modified:
camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
Modified: camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java?rev=766587&r1=766586&r2=766587&view=diff
==============================================================================
--- camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java (original)
+++ camel/branches/camel-1.x/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java Mon Apr 20 06:22:02 2009
@@ -44,7 +44,7 @@
executor.afterPropertiesSet();
executor.execute(new Runnable() {
public void run() {
- for (int i = 0; i < 20; i++) {
+ for (int i = 0; i < 10; i++) {
// when this delay is removed, the seda endpoint has ordering issues
try {
// do some random sleep to simulate spread in user activity
@@ -66,7 +66,7 @@
public void testStartStopConsumer() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMessageCount(20);
+ mock.expectedMessageCount(10);
mock.expectsAscending(body());
initRoute();
@@ -74,7 +74,7 @@
sendMessagesToQueue();
consumer.start();
- for (int i = 0; i < 20; i++) {
+ for (int i = 0; i < 10; i++) {
if (i == 10) {
// stop while sending, and then start again to pickup what is left in the queue
consumer.stop();