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 2017/01/09 09:09:26 UTC
svn commit: r1777941 - in
/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs:
queues/QueueManager.java tasks/CheckTopologyTask.java
Author: cziegeler
Date: Mon Jan 9 09:09:26 2017
New Revision: 1777941
URL: http://svn.apache.org/viewvc?rev=1777941&view=rev
Log:
SLING-5454 : Improve logging on startup of QueueManager and Job reassignment. Apply patch from J�rg Hoh
Modified:
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/QueueManager.java
sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/tasks/CheckTopologyTask.java
Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/QueueManager.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/QueueManager.java?rev=1777941&r1=1777940&r2=1777941&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/QueueManager.java (original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/queues/QueueManager.java Mon Jan 9 09:09:26 2017
@@ -132,7 +132,7 @@ public class QueueManager
*/
@Activate
protected void activate(final Map<String, Object> props) {
- logger.info("Apache Sling Queue Manager started on instance {}", Environment.APPLICATION_ID);
+ logger.info("Apache Sling Queue Manager starting on instance {}", Environment.APPLICATION_ID);
this.queueServices = new QueueServices();
queueServices.configuration = this.configuration;
queueServices.eventAdmin = this.eventAdmin;
@@ -142,6 +142,7 @@ public class QueueManager
queueServices.statisticsManager = statisticsManager;
queueServices.eventingThreadPool = this.threadPool;
this.configuration.addListener(this);
+ logger.info("Apache Sling Queue Manager started on instance {}", Environment.APPLICATION_ID);
}
/**
Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/tasks/CheckTopologyTask.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/tasks/CheckTopologyTask.java?rev=1777941&r1=1777940&r2=1777941&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/tasks/CheckTopologyTask.java (original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/jobs/tasks/CheckTopologyTask.java Mon Jan 9 09:09:26 2017
@@ -131,6 +131,7 @@ public class CheckTopologyTask {
break;
}
final QueueInfo info = qcm.getQueueInfo(topicName);
+ logger.info ("Start reassigning stale jobs");
JobTopicTraverser.traverse(this.logger, topicResource, new JobTopicTraverser.ResourceCallback() {
@Override