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
