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/06/25 07:26:02 UTC
svn commit: r788264 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java
Author: davsclaus
Date: Thu Jun 25 05:26:02 2009
New Revision: 788264
URL: http://svn.apache.org/viewvc?rev=788264&view=rev
Log:
Fixed an issue with stop() in pipeline.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java?rev=788264&r1=788263&r2=788264&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/Pipeline.java Thu Jun 25 05:26:02 2009
@@ -21,7 +21,6 @@
import java.util.List;
import org.apache.camel.Exchange;
-import org.apache.camel.Message;
import org.apache.camel.Processor;
import org.apache.camel.util.ExchangeHelper;
import org.apache.commons.logging.Log;
@@ -149,12 +148,11 @@
LOG.debug("Exchange is marked to stop routing: " + exchange);
}
return false;
- } else {
- return true;
}
- } else {
- return it.hasNext();
}
+
+ // continue if there are more processors to route
+ return it.hasNext();
}
@Override