incubator-sling-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cziege...@apache.org
Subject svn commit: r891177 - in /sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl: AbstractRepositoryEventHandler.java JobEventHandler.java
Date Wed, 16 Dec 2009 10:13:19 GMT
Author: cziegeler
Date: Wed Dec 16 10:13:18 2009
New Revision: 891177

URL: http://svn.apache.org/viewvc?rev=891177&view=rev
Log:
SLING-1243 : Scheduler reference is not defined for job event handler

Modified:
    sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/AbstractRepositoryEventHandler.java
    sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java

Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/AbstractRepositoryEventHandler.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/AbstractRepositoryEventHandler.java?rev=891177&r1=891176&r2=891177&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/AbstractRepositoryEventHandler.java
(original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/AbstractRepositoryEventHandler.java
Wed Dec 16 10:13:18 2009
@@ -319,7 +319,7 @@
      */
     protected void ignoreException(Exception e) {
         if ( this.logger.isDebugEnabled() ) {
-            this.logger.debug("Ignore exception " + e.getMessage(), e);
+            this.logger.debug("Ignored exception " + e.getMessage(), e);
         }
     }
 

Modified: sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java?rev=891177&r1=891176&r2=891177&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java
(original)
+++ sling/trunk/bundles/extensions/event/src/main/java/org/apache/sling/event/impl/JobEventHandler.java
Wed Dec 16 10:13:18 2009
@@ -137,7 +137,8 @@
     /** We remove everything which is older than 5 min by default. */
     private int cleanupPeriod = DEFAULT_CLEANUP_PERIOD;
 
-    /** The scheduler for rescheduling jobs. @scr.reference */
+    /** The scheduler for rescheduling jobs.
+     * @scr.reference */
     private Scheduler scheduler;
 
     /** Our component context. */
@@ -456,6 +457,9 @@
         // load unprocessed jobs from repository
         if ( this.running ) {
             this.loadJobs();
+            logger.info("Apache Sling Job Event Handler started.");
+            logger.debug("Job Handler Configuration: (sleepTime={}secs,maxJobRetries={},waitForAck={}ms,maximumParallelJobs={},cleanupPeriod={}min)",
+                    new Object[] {sleepTime, maxJobRetries,waitForAckMs,maximumParallelJobs,cleanupPeriod});
         } else {
             final ComponentContext ctx = this.componentContext;
             // deactivate
@@ -720,7 +724,7 @@
         // if this is the main queue and we have reached the max number of parallel jobs
         // we wait a little bit before continuing
         if ( wait ) {
-            logger.debug("Sleeping for {} seconds.", sleepTime);
+            logger.debug("Sleeping for {} seconds as the maximum number of parallel threads
is reached.", sleepTime);
             try {
                 Thread.sleep(sleepTime * 1000);
             } catch (InterruptedException ie) {



Mime
View raw message