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 2013/06/13 19:51:17 UTC
svn commit: r1492784 -
/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java
Author: cziegeler
Date: Thu Jun 13 17:51:16 2013
New Revision: 1492784
URL: http://svn.apache.org/r1492784
Log:
SLING-2906 : Queue might be outdated and closed while still processing
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=1492784&r1=1492783&r2=1492784&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 Thu Jun 13 17:51:16 2013
@@ -212,7 +212,10 @@ public abstract class AbstractJobQueue
return false;
}
- private boolean canBeClosed() {
+ /**
+ * Check whether this queue can be closed
+ */
+ protected boolean canBeClosed() {
return this.isEmpty() && !this.isWaiting && !this.isSuspended() && this.asyncCounter.get() == 0 && this.isWaitingForNext;
}