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 2010/12/29 16:15:39 UTC
svn commit: r1053648 -
/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/AbstractJobQueue.java
Author: cziegeler
Date: Wed Dec 29 15:15:37 2010
New Revision: 1053648
URL: http://svn.apache.org/viewvc?rev=1053648&view=rev
Log:
Correctly handle queue count if no ack has been received
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=1053648&r1=1053647&r2=1053648&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 Wed Dec 29 15:15:37 2010
@@ -215,8 +215,8 @@ public abstract class AbstractJobQueue
process = this.startedJobsLists.remove(info.uniqueId) != null;
}
if ( process ) {
- this.decQueued();
if ( !info.reschedule() ) {
+ this.decQueued();
checkForNotify(null);
} else {
this.logger.info("No acknowledge received for job {} stored at {}. Requeueing job.", EventUtil.toString(info.event), info.uniqueId);