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/09/15 10:45:21 UTC
svn commit: r815220 - in
/camel/trunk/camel-core/src/main/java/org/apache/camel/processor:
StreamResequencer.java resequencer/ResequencerEngine.java
Author: davsclaus
Date: Tue Sep 15 08:45:21 2009
New Revision: 815220
URL: http://svn.apache.org/viewvc?rev=815220&view=rev
Log:
fixed spelling and resequencer should stop when camel is stopping
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java
camel/trunk/camel-core/src/main/java/org/apache/camel/processor/resequencer/ResequencerEngine.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java?rev=815220&r1=815219&r2=815220&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/StreamResequencer.java Tue Sep 15 08:45:21 2009
@@ -193,7 +193,7 @@
@Override
public void run() {
- while (true) {
+ while (isRunAllowed()) {
try {
deliveryRequestLock.lock();
try {
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/processor/resequencer/ResequencerEngine.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/resequencer/ResequencerEngine.java?rev=815220&r1=815219&r2=815220&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/processor/resequencer/ResequencerEngine.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/processor/resequencer/ResequencerEngine.java Tue Sep 15 08:45:21 2009
@@ -223,7 +223,7 @@
/**
* Attempts to deliver a single element from the head of the resequencer
* queue (sequence). Only elements which have not been scheduled for timing
- * out or which already timed out can be delivered. Elements are deliveref via
+ * out or which already timed out can be delivered. Elements are delivered via
* {@link SequenceSender#sendElement(Object)}.
*
* @return <code>true</code> if the element has been delivered