Author: cziegeler
Date: Tue Aug 31 15:16:30 2010
New Revision: 991216
URL: http://svn.apache.org/viewvc?rev=991216&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=991216&r1=991215&r2=991216&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:16:30 2010
@@ -136,7 +136,7 @@ public final class JobBlockingQueue exte
* Check if this queue is marked for cleanup
*/
public boolean isMarkedForCleanUp() {
- return !this.isWaiting && this.markForCleanUp;
+ return !this.isWaiting && this.markForCleanUp && this.jobCount == 0;
}
/**
