Author: cziegeler
Date: Tue Oct 26 08:59:24 2010
New Revision: 1027409

URL: http://svn.apache.org/viewvc?rev=1027409&view=rev
Log:
Clear markedForCleanup flag if queue should not be removed

Modified:
    
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java

Modified: 
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java?rev=1027409&r1=1027408&r2=1027409&view=diff
==============================================================================
--- 
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java
 (original)
+++ 
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java
 Tue Oct 26 08:59:24 2010
@@ -373,7 +373,13 @@ public abstract class AbstractJobQueue
      * Check if this queue is marked for cleanup
      */
     public boolean isMarkedForCleanUp() {
-        return this.markedForCleanUp && this.canBeMarkedForCleanUp();
+        if ( this.markedForCleanUp ) {
+            if ( this.canBeMarkedForCleanUp() ) {
+                return true;
+            }
+            this.markedForCleanUp = false;
+        }
+        return false;
     }
 
     /**


Reply via email to