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/02/03 14:09:45 UTC
svn commit: r740294 - in
/camel/trunk/camel-core/src/test/java/org/apache/camel:
component/seda/SedaConsumerStartStopTest.java
processor/DelayInterceptorTest.java
Author: davsclaus
Date: Tue Feb 3 13:09:45 2009
New Revision: 740294
URL: http://svn.apache.org/viewvc?rev=740294&view=rev
Log:
Trying to fix failing tests reported by teamcity
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DelayInterceptorTest.java
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java?rev=740294&r1=740293&r2=740294&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/component/seda/SedaConsumerStartStopTest.java Tue Feb 3 13:09:45 2009
@@ -42,7 +42,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
@@ -64,7 +64,7 @@
public void testStartStopConsumer() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
- mock.expectedMessageCount(20);
+ mock.expectedMessageCount(10);
mock.expectsAscending(body());
initRoute();
@@ -72,11 +72,11 @@
sendMessagesToQueue();
consumer.start();
- for (int i = 0; i < 20; i++) {
- if (i == 10) {
+ for (int i = 0; i < 10; i++) {
+ if (i == 5) {
// stop while sending, and then start again to pickup what is left in the queue
consumer.stop();
- Thread.sleep(900);
+ Thread.sleep(500);
consumer.start();
}
// use 1000 as timeout otherwise we might get null if the consumer hasn't been started again
Modified: camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DelayInterceptorTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DelayInterceptorTest.java?rev=740294&r1=740293&r2=740294&view=diff
==============================================================================
--- camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DelayInterceptorTest.java (original)
+++ camel/trunk/camel-core/src/test/java/org/apache/camel/processor/DelayInterceptorTest.java Tue Feb 3 13:09:45 2009
@@ -35,8 +35,8 @@
template.sendBody("direct:start", "Message #" + i);
}
long delta = System.currentTimeMillis() - start;
- assertTrue("Should be slower to run: " + delta, delta > 4000);
- assertTrue("Should not take that long to run: " + delta, delta < 7000);
+ assertTrue("Should not be that fast to run: " + delta, delta > 4000);
+ assertTrue("Should not take that long to run: " + delta, delta < 9000);
}
@Override