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/05/16 15:35:42 UTC
svn commit: r1483355 -
/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java
Author: cziegeler
Date: Thu May 16 13:35:42 2013
New Revision: 1483355
URL: http://svn.apache.org/r1483355
Log:
SLING-2868 : Improve and cleanup implementation : don't wait for resume on shutdown
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=1483355&r1=1483354&r2=1483355&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 May 16 13:35:42 2013
@@ -470,8 +470,9 @@ public abstract class AbstractJobQueue
info = this.take();
}
- checkSuspended();
-
+ if ( this.running ) {
+ checkSuspended();
+ }
if ( info != null && this.running ) {
info = this.start(info);
}