diff options
author | Pamela Dragosh <pdragosh@research.att.com> | 2020-06-29 16:40:17 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2020-06-29 16:40:17 +0000 |
commit | cbf8332c2438bb8fe444758fdb514b033c8482cb (patch) | |
tree | 1f7762316af2ebcc990798fbd7ececf68233ee48 /main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java | |
parent | 81bfcc1729235abebfa4cd2c35cf37aedcadc376 (diff) | |
parent | 552af85d4daa66dff8d4b920db61fe6010eee388 (diff) |
Merge "Parallel execution of Client Health check"
Diffstat (limited to 'main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java')
-rw-r--r-- | main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java b/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java index fd13c232..4272e491 100644 --- a/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java +++ b/main/src/main/java/org/onap/policy/pap/main/startstop/PapActivator.java @@ -25,6 +25,7 @@ import java.util.Arrays; import java.util.concurrent.atomic.AtomicReference; import org.onap.policy.common.endpoints.event.comm.TopicEndpointManager; import org.onap.policy.common.endpoints.event.comm.TopicSource; +import org.onap.policy.common.endpoints.http.client.HttpClientFactoryInstance; import org.onap.policy.common.endpoints.http.server.RestServer; import org.onap.policy.common.endpoints.listeners.MessageTypeDispatcher; import org.onap.policy.common.endpoints.listeners.RequestIdDispatcher; @@ -57,6 +58,7 @@ import org.onap.policy.pap.main.rest.PdpGroupHealthCheckControllerV1; import org.onap.policy.pap.main.rest.PdpGroupQueryControllerV1; import org.onap.policy.pap.main.rest.PdpGroupStateChangeControllerV1; import org.onap.policy.pap.main.rest.PolicyComponentsHealthCheckControllerV1; +import org.onap.policy.pap.main.rest.PolicyComponentsHealthCheckProvider; import org.onap.policy.pap.main.rest.PolicyStatusControllerV1; import org.onap.policy.pap.main.rest.PolicyUndeployerImpl; import org.onap.policy.pap.main.rest.StatisticsRestControllerV1; @@ -236,6 +238,12 @@ public class PapActivator extends ServiceManagerContainer { .build()), () -> Registry.unregister(PapConstants.REG_PDP_TRACKER)); + addAction("PAP client executor", + () -> + PolicyComponentsHealthCheckProvider.initializeClientHealthCheckExecutorService(papParameterGroup, + HttpClientFactoryInstance.getClientFactory()), + PolicyComponentsHealthCheckProvider::cleanup); + addAction("REST server", () -> { RestServer server = new RestServer(papParameterGroup.getRestServerParameters(), PapAafFilter.class, |