incubator-sling-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cziege...@apache.org
Subject svn commit: r1492739 - /sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/OrderedJobQueue.java
Date Thu, 13 Jun 2013 16:22:26 GMT
Author: cziegeler
Date: Thu Jun 13 16:22:25 2013
New Revision: 1492739

URL: http://svn.apache.org/r1492739
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/OrderedJobQueue.java

Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/OrderedJobQueue.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/OrderedJobQueue.java?rev=1492739&r1=1492738&r2=1492739&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/OrderedJobQueue.java
(original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/OrderedJobQueue.java
Thu Jun 13 16:22:25 2013
@@ -149,6 +149,7 @@ public final class OrderedJobQueue exten
                 } catch (final InterruptedException e) {
                     this.ignoreException(e);
                 }
+                this.isWaitingForNext = false;
             }
             // get the first element and remove it
             final Iterator<JobHandler> i = this.queue.iterator();



Mime
View raw message