You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by cz...@apache.org on 2010/10/26 10:59:24 UTC

svn commit: r1027409 - /sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java

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;
     }
 
     /**