svn commit: r991215 - /sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java

[cziegeler]

Author: cziegeler
Date: Tue Aug 31 15:15:04 2010
New Revision: 991215

URL: http://svn.apache.org/viewvc?rev=991215&view=rev
Log:
SLING-1536 : Job Queue might be stopped during job processing

Modified:
    
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java

Modified: 
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java?rev=991215&r1=991214&r2=991215&view=diff
==============================================================================
--- 
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java
 (original)
+++ 
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/job/JobBlockingQueue.java
 Tue Aug 31 15:15:04 2010
@@ -97,7 +97,7 @@ public final class JobBlockingQueue exte
      * Mark this queue for cleanup.
      */
     public void markForCleanUp() {
-        if ( !this.isWaiting ) {
+        if ( !this.isWaiting && jobCount == 0 ) {
             this.markForCleanUp = true;
         }
     }