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 2015/04/30 16:30:03 UTC
svn commit: r1677005 -
/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/config/TopologyHandler.java
Author: cziegeler
Date: Thu Apr 30 14:30:03 2015
New Revision: 1677005
URL: http://svn.apache.org/r1677005
Log:
SLING-4683 : Ensure that topology change events are processed quickly
Modified:
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/config/TopologyHandler.java
Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/config/TopologyHandler.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/config/TopologyHandler.java?rev=1677005&r1=1677004&r2=1677005&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/config/TopologyHandler.java (original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/config/TopologyHandler.java Thu Apr 30 14:30:03 2015
@@ -60,6 +60,7 @@ public class TopologyHandler implements
@Deactivate
protected void deactivate() {
this.isActive.set(false);
+ this.queue.clear();
try {
this.queue.put(new QueueItem());
} catch ( final InterruptedException ie) {