commit 724cd65ae6c78b44f4bef3a39f65047d54cd0bae
author Carsten Ziegeler <cziegeler@apache.org> Tue Aug 31 15:16:30 2010 +0000
committer Carsten Ziegeler <cziegeler@apache.org> Tue Aug 31 15:16:30 2010 +0000
tree 398daa76d14bf7d5fdc85a12f2b61e6c4f6a655c
parent 061ddd9f72b9991f88d8247999c60591d5da22a3

SLING-1536 : Job Queue might be stopped during job processing

git-svn-id: https://svn.apache.org/repos/asf/sling/trunk/bundles/extensions/event@991216 13f79535-47bb-0310-9956-ffa450edef68

src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java

diff --git a/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java b/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java
index d0dafe4..54b2b31 100644
--- a/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java
+++ b/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java
@@ -136,7 +136,7 @@
      * Check if this queue is marked for cleanup
      */
     public boolean isMarkedForCleanUp() {
-        return !this.isWaiting && this.markForCleanUp;
+        return !this.isWaiting && this.markForCleanUp && this.jobCount == 0;
     }
 
     /**