This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit dab077597d9b29218360ef8dba8aad34060f72ac Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu May 28 09:21:50 2020 +0200 CAMEL-15126: camel-health - Remove unusued api from spi --- .../org/apache/camel/health/HealthCheckService.java | 18 +----------------- .../camel/impl/health/DefaultHealthCheckService.java | 15 +++++++++++++-- 2 files changed, 14 insertions(+), 19 deletions(-) diff --git a/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckService.java b/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckService.java index 5a2acd3..706caa9 100644 --- a/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckService.java +++ b/core/camel-api/src/main/java/org/apache/camel/health/HealthCheckService.java @@ -20,33 +20,17 @@ import java.util.Collection; import java.util.Collections; import java.util.Map; import java.util.Optional; -import java.util.function.BiConsumer; import org.apache.camel.CamelContextAware; -import org.apache.camel.Service; import org.apache.camel.StaticService; /** - * An health check service that invokes the checks registered on the {@link HealthCheckRegistry} + * An health check service that invokes the {@link HealthCheck} registered on the {@link HealthCheckRegistry} * according to a schedule. */ public interface HealthCheckService extends StaticService, CamelContextAware { /** - * Add a listener to invoke when the state of a check change. - * - * @param consumer the event listener. - */ - void addStateChangeListener(BiConsumer<HealthCheck.State, HealthCheck> consumer); - - /** - * Remove the state change listener. - * - * @param consumer the event listener to remove. - */ - void removeStateChangeListener(BiConsumer<HealthCheck.State, HealthCheck> consumer); - - /** * Sets the options to be used when invoking the check identified by the * given id. * diff --git a/core/camel-health/src/main/java/org/apache/camel/impl/health/DefaultHealthCheckService.java b/core/camel-health/src/main/java/org/apache/camel/impl/health/DefaultHealthCheckService.java index 046ca4c..e2d3d8e 100644 --- a/core/camel-health/src/main/java/org/apache/camel/impl/health/DefaultHealthCheckService.java +++ b/core/camel-health/src/main/java/org/apache/camel/impl/health/DefaultHealthCheckService.java @@ -44,6 +44,9 @@ import org.apache.camel.util.concurrent.LockHelper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/** + * Default {@link HealthCheckService} + */ public final class DefaultHealthCheckService extends ServiceSupport implements HealthCheckService { private static final Logger LOGGER = LoggerFactory.getLogger(DefaultHealthCheckService.class); @@ -102,7 +105,11 @@ public final class DefaultHealthCheckService extends ServiceSupport implements H this.checkInterval = checkInterval; } - @Override + /** + * Add a listener to invoke when the state of a check change. + * + * @param consumer the event listener. + */ public void addStateChangeListener(BiConsumer<HealthCheck.State, HealthCheck> consumer) { LockHelper.doWithWriteLock( lock, @@ -110,7 +117,11 @@ public final class DefaultHealthCheckService extends ServiceSupport implements H ); } - @Override + /** + * Remove the state change listener. + * + * @param consumer the event listener to remove. + */ public void removeStateChangeListener(BiConsumer<HealthCheck.State, HealthCheck> consumer) { LockHelper.doWithWriteLock( lock,