incubator-sling-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cziege...@apache.org
Subject svn commit: r1492784 - /sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java
Date Thu, 13 Jun 2013 17:51:17 GMT
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;
     }
 



Mime
View raw message