You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by bd...@apache.org on 2014/07/30 15:31:16 UTC

svn commit: r1614659 - /sling/trunk/bundles/extensions/healthcheck/core/src/main/java/org/apache/sling/hc/core/impl/executor/AsyncHealthCheckExecutor.java

Author: bdelacretaz
Date: Wed Jul 30 13:31:15 2014
New Revision: 1614659

URL: http://svn.apache.org/r1614659
Log:
SLING-3744 - if a health check takes a long time to execute we should wait until it's finished before executing it again

Modified:
    sling/trunk/bundles/extensions/healthcheck/core/src/main/java/org/apache/sling/hc/core/impl/executor/AsyncHealthCheckExecutor.java

Modified: sling/trunk/bundles/extensions/healthcheck/core/src/main/java/org/apache/sling/hc/core/impl/executor/AsyncHealthCheckExecutor.java
URL: http://svn.apache.org/viewvc/sling/trunk/bundles/extensions/healthcheck/core/src/main/java/org/apache/sling/hc/core/impl/executor/AsyncHealthCheckExecutor.java?rev=1614659&r1=1614658&r2=1614659&view=diff
==============================================================================
--- sling/trunk/bundles/extensions/healthcheck/core/src/main/java/org/apache/sling/hc/core/impl/executor/AsyncHealthCheckExecutor.java (original)
+++ sling/trunk/bundles/extensions/healthcheck/core/src/main/java/org/apache/sling/hc/core/impl/executor/AsyncHealthCheckExecutor.java Wed Jul 30 13:31:15 2014
@@ -137,7 +137,8 @@ public class AsyncHealthCheckExecutor im
         try {
             HealthCheckAsyncJob healthCheckAsyncJob = new HealthCheckAsyncJob(descriptor);
             LOG.debug("Scheduling job {} with cron expression {}", healthCheckAsyncJob, descriptor.getAsyncCronExpression());
-            this.scheduler.addJob(healthCheckAsyncJob.getJobId(), healthCheckAsyncJob, null, descriptor.getAsyncCronExpression(), true);
+            final boolean concurrent = false;
+            this.scheduler.addJob(healthCheckAsyncJob.getJobId(), healthCheckAsyncJob, null, descriptor.getAsyncCronExpression(), concurrent);
             registeredJobs.put(descriptor, healthCheckAsyncJob);
             return true;
         } catch (Exception e) {