aboutsummaryrefslogtreecommitdiffstats
path: root/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DmaapHealth.java
diff options
context:
space:
mode:
Diffstat (limited to 'catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DmaapHealth.java')
-rw-r--r--catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DmaapHealth.java216
1 files changed, 111 insertions, 105 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DmaapHealth.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DmaapHealth.java
index 0515b08b2e..96ac07063d 100644
--- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DmaapHealth.java
+++ b/catalog-be/src/main/java/org/openecomp/sdc/be/components/distribution/engine/DmaapHealth.java
@@ -7,9 +7,9 @@
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -17,20 +17,12 @@
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-
package org.openecomp.sdc.be.components.distribution.engine;
-import org.apache.commons.validator.routines.UrlValidator;
-import org.apache.http.client.utils.URIUtils;
-import org.openecomp.sdc.be.config.BeEcompErrorManager;
-import org.openecomp.sdc.be.config.ConfigurationManager;
-import org.openecomp.sdc.be.config.DmaapConsumerConfiguration;
-import org.openecomp.sdc.common.api.HealthCheckInfo;
-import org.openecomp.sdc.common.log.wrappers.Logger;
-import org.springframework.stereotype.Component;
+import static org.apache.commons.lang3.StringUtils.countMatches;
+import static org.apache.commons.lang3.StringUtils.isNotBlank;
+import static org.openecomp.sdc.common.api.Constants.HC_COMPONENT_DMAAP_ENGINE;
-import javax.annotation.PostConstruct;
-import javax.annotation.PreDestroy;
import java.io.IOException;
import java.net.InetAddress;
import java.net.URI;
@@ -40,76 +32,78 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicBoolean;
-
-import static org.apache.commons.lang3.StringUtils.countMatches;
-import static org.apache.commons.lang3.StringUtils.isNotBlank;
-import static org.openecomp.sdc.common.api.Constants.HC_COMPONENT_DMAAP_ENGINE;
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
+import org.apache.commons.validator.routines.UrlValidator;
+import org.apache.http.client.utils.URIUtils;
+import org.openecomp.sdc.be.config.BeEcompErrorManager;
+import org.openecomp.sdc.be.config.ConfigurationManager;
+import org.openecomp.sdc.be.config.DmaapConsumerConfiguration;
+import org.openecomp.sdc.common.api.HealthCheckInfo;
+import org.openecomp.sdc.common.log.wrappers.Logger;
+import org.springframework.stereotype.Component;
@Component("dmaapHealth")
public class DmaapHealth {
-
private static final String DMAAP_HEALTH_LOG_CONTEXT = "dmaap.healthcheck";
private static final String DMAAP_HEALTH_CHECK_STR = "dmaapHealthCheck";
private static final Logger log = Logger.getLogger(DmaapHealth.class.getName());
private static final Logger logHealth = Logger.getLogger(DMAAP_HEALTH_LOG_CONTEXT);
+ private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
private HealthCheckInfo healthCheckInfo = DmaapHealth.HealthCheckInfoResult.UNAVAILABLE.getHealthCheckInfo();
private long healthCheckReadTimeout = 20;
private long reconnectInterval = 5;
- private HealthCheckScheduledTask healthCheckScheduledTask = null ;
- private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
+ private HealthCheckScheduledTask healthCheckScheduledTask = null;
private ScheduledFuture<?> scheduledFuture = null;
- private DmaapConsumerConfiguration configuration = null ;
-
+ private DmaapConsumerConfiguration configuration = null;
private volatile AtomicBoolean lastHealthState = new AtomicBoolean(false);
private volatile AtomicBoolean reportedHealthState = null;
- public enum HealthCheckInfoResult {
- OK(new HealthCheckInfo(HC_COMPONENT_DMAAP_ENGINE, HealthCheckInfo.HealthCheckStatus.UP, null, DmaapStatusDescription.OK.getDescription())),
- UNAVAILABLE(new HealthCheckInfo(HC_COMPONENT_DMAAP_ENGINE, HealthCheckInfo.HealthCheckStatus.DOWN, null, DmaapStatusDescription.UNAVAILABLE.getDescription())),
- DOWN(new HealthCheckInfo(HC_COMPONENT_DMAAP_ENGINE, HealthCheckInfo.HealthCheckStatus.DOWN, null, DmaapStatusDescription.DOWN.getDescription()));
-
- private HealthCheckInfo healthCheckInfo;
- HealthCheckInfoResult(HealthCheckInfo healthCheckInfo) {
- this.healthCheckInfo = healthCheckInfo;
- }
- public HealthCheckInfo getHealthCheckInfo() {
- return healthCheckInfo;
+ public static String getUrlHost(String qualifiedHost) throws URISyntaxException {
+ //region - parse complex format ex. <http://URL:PORT>
+ try {
+ UrlValidator validator = new UrlValidator();
+ if (validator.isValid(qualifiedHost)) {
+ return URIUtils.extractHost(new URI(qualifiedHost)).getHostName();
+ } else {
+ log.debug("{} - invalid url format, continuing ", DMAAP_HEALTH_CHECK_STR);
+ }
+ } catch (URISyntaxException e) {
+ log.debug("{} - invalid url format, continuing {} ", DMAAP_HEALTH_CHECK_STR, e);
}
- }
-
- public enum DmaapStatusDescription {
- OK("OK"), UNAVAILABLE("Dmaap is not available"),DOWN("DOWN"), NOT_CONFIGURED("Dmaap configuration is missing/wrong ");
+ //endregion
- private String desc;
- DmaapStatusDescription(String desc) {
- this.desc = desc;
- }
- public String getDescription() {
- return desc;
+ //region - try shortcut format <URL> or <URL:PORT>
+ if (countMatches(qualifiedHost, ":") <= 1) {
+ String[] address = qualifiedHost.split(":");
+ if (address.length > 0 && isNotBlank(address[0])) {
+ return address[0];
+ }
}
-
+ //endregion
+ throw new URISyntaxException(qualifiedHost,
+ "invalid hostname, expecting a single <host:port> , (valid ex. www.google.com:80 | www.google.com | http:\\\\www.google.com:8181)");
}
@PostConstruct
public DmaapHealth init() {
- if(!ConfigurationManager.getConfigurationManager().getConfiguration().getDmaapConsumerConfiguration().isActive()){
+ if (!ConfigurationManager.getConfigurationManager().getConfiguration().getDmaapConsumerConfiguration().isActive()) {
log.debug("Dmaap health check task disabled");
return this;
}
log.trace("Enter init method of Dmaap health");
- synchronized (DmaapHealth.class){
+ synchronized (DmaapHealth.class) {
this.configuration = ConfigurationManager.getConfigurationManager().getConfiguration().getDmaapConsumerConfiguration();
-
Integer pollingInterval = configuration.getPollingInterval();
- if (pollingInterval != null && pollingInterval!=0) {
+ if (pollingInterval != null && pollingInterval != 0) {
reconnectInterval = pollingInterval;
}
Integer healthCheckReadTimeoutConfig = configuration.getTimeoutMs();
if (healthCheckReadTimeoutConfig != null) {
this.healthCheckReadTimeout = healthCheckReadTimeoutConfig;
}
- this.healthCheckScheduledTask = new HealthCheckScheduledTask( configuration ); //what is the representation? csv? delimiter? json or other
+ this.healthCheckScheduledTask = new HealthCheckScheduledTask(configuration); //what is the representation? csv? delimiter? json or other
startHealthCheckTask(true);
}
log.trace("Exit init method of DistributionEngineClusterHealth");
@@ -133,110 +127,122 @@ public class DmaapHealth {
* @param startTask
*/
private void startHealthCheckTask(boolean startTask) {
- synchronized (DmaapHealth.class){
+ synchronized (DmaapHealth.class) {
if (startTask && this.scheduledFuture == null) {
- this.scheduledFuture = this.scheduler.scheduleAtFixedRate(this.healthCheckScheduledTask , 0, reconnectInterval, TimeUnit.SECONDS);
+ this.scheduledFuture = this.scheduler.scheduleAtFixedRate(this.healthCheckScheduledTask, 0, reconnectInterval, TimeUnit.SECONDS);
}
}
}
- void report(Boolean isUp){
- if (reportedHealthState == null)
+ void report(Boolean isUp) {
+ if (reportedHealthState == null) {
reportedHealthState = new AtomicBoolean(isUp);
+ }
reportedHealthState.set(isUp);
}
-
public HealthCheckInfo getHealthCheckInfo() {
return healthCheckInfo;
}
+ public enum HealthCheckInfoResult {
+ // @formatter:off
+ OK(new HealthCheckInfo(HC_COMPONENT_DMAAP_ENGINE, HealthCheckInfo.HealthCheckStatus.UP, null, DmaapStatusDescription.OK.getDescription())),
+ UNAVAILABLE(new HealthCheckInfo(HC_COMPONENT_DMAAP_ENGINE, HealthCheckInfo.HealthCheckStatus.DOWN, null, DmaapStatusDescription.UNAVAILABLE.getDescription())),
+ DOWN(new HealthCheckInfo(HC_COMPONENT_DMAAP_ENGINE, HealthCheckInfo.HealthCheckStatus.DOWN, null, DmaapStatusDescription.DOWN.getDescription()));
+ // @formatter:on
+
+ private HealthCheckInfo healthCheckInfo;
+
+ HealthCheckInfoResult(HealthCheckInfo healthCheckInfo) {
+ this.healthCheckInfo = healthCheckInfo;
+ }
+
+ public HealthCheckInfo getHealthCheckInfo() {
+ return healthCheckInfo;
+ }
+ }
+
+ public enum DmaapStatusDescription {
+ // @formatter:off
+ OK("OK"),
+ UNAVAILABLE("Dmaap is not available"),
+ DOWN("DOWN"),
+ NOT_CONFIGURED("Dmaap configuration is missing/wrong ");
+ // @formatter:on
+
+ private String desc;
+
+ DmaapStatusDescription(String desc) {
+ this.desc = desc;
+ }
+
+ public String getDescription() {
+ return desc;
+ }
+
+ }
+
/**
* Health Check Task Scheduler - infinite check.
*/
public class HealthCheckScheduledTask implements Runnable {
- private final DmaapConsumerConfiguration config;
+
private static final int TIMEOUT = 8192;
+ private final DmaapConsumerConfiguration config;
- HealthCheckScheduledTask(final DmaapConsumerConfiguration config){
+ HealthCheckScheduledTask(final DmaapConsumerConfiguration config) {
this.config = config;
}
+
@Override
public void run() {
logHealth.trace("Executing Dmaap Health Check Task - Start");
boolean prevIsReachable;
boolean reachable;
//first try simple ping
- try{
- if ( reportedHealthState != null ){
+ try {
+ if (reportedHealthState != null) {
reachable = reportedHealthState.get();
+ } else {
+ reachable = false;
}
- else{
- reachable = false;
- }
- prevIsReachable = lastHealthState.getAndSet( reachable );
+ prevIsReachable = lastHealthState.getAndSet(reachable);
healthCheckInfo = reachable ? HealthCheckInfoResult.OK.healthCheckInfo : HealthCheckInfoResult.DOWN.healthCheckInfo;
- }
- catch( Exception e ){
- log.debug("{} - cannot check connectivity -> {}",DMAAP_HEALTH_CHECK_STR, e );
+ } catch (Exception e) {
+ log.debug("{} - cannot check connectivity -> {}", DMAAP_HEALTH_CHECK_STR, e);
prevIsReachable = lastHealthState.getAndSet(false);
healthCheckInfo = HealthCheckInfoResult.UNAVAILABLE.healthCheckInfo;
}
- if (prevIsReachable != lastHealthState.get())
- logAlarm( lastHealthState.get() );
+ if (prevIsReachable != lastHealthState.get()) {
+ logAlarm(lastHealthState.get());
+ }
}
-
/**
* @deprecated (health is reported outside from EnvironmentEngine consumer fetch)
*/
@Deprecated
- public boolean isICMPReachable( ) throws IOException{
- try{
+ public boolean isICMPReachable() throws IOException {
+ try {
String hostname = getUrlHost(config.getHosts());
- return InetAddress.getByName( hostname ).isReachable(TIMEOUT);
- }catch( URISyntaxException e ){
- log.debug("{} - malformed host configuration -> ",DMAAP_HEALTH_CHECK_STR , e);
+ return InetAddress.getByName(hostname).isReachable(TIMEOUT);
+ } catch (URISyntaxException e) {
+ log.debug("{} - malformed host configuration -> ", DMAAP_HEALTH_CHECK_STR, e);
}
return false;
}
private void logAlarm(boolean lastHealthState) {
- try{
- if ( lastHealthState ) {
- BeEcompErrorManager.getInstance().logDmaapHealthCheckRecovery( DMAAP_HEALTH_CHECK_STR );
+ try {
+ if (lastHealthState) {
+ BeEcompErrorManager.getInstance().logDmaapHealthCheckRecovery(DMAAP_HEALTH_CHECK_STR);
} else {
- BeEcompErrorManager.getInstance().logDmaapHealthCheckError( DMAAP_HEALTH_CHECK_STR );
+ BeEcompErrorManager.getInstance().logDmaapHealthCheckError(DMAAP_HEALTH_CHECK_STR);
}
- }catch( Exception e ){
- log.debug("cannot logAlarm -> {}" ,e );
- }
- }
-
- }
-
- public static String getUrlHost(String qualifiedHost) throws URISyntaxException{
- //region - parse complex format ex. <http://URL:PORT>
- try{
- UrlValidator validator = new UrlValidator();
- if (validator.isValid(qualifiedHost)){
- return URIUtils.extractHost(new URI(qualifiedHost)).getHostName();
- }else{
- log.debug("{} - invalid url format, continuing ", DMAAP_HEALTH_CHECK_STR );
+ } catch (Exception e) {
+ log.debug("cannot logAlarm -> {}", e);
}
- }catch(URISyntaxException e){
- log.debug("{} - invalid url format, continuing {} ", DMAAP_HEALTH_CHECK_STR , e);
}
- //endregion
-
- //region - try shortcut format <URL> or <URL:PORT>
- if ( countMatches( qualifiedHost , ":") <= 1){
- String[] address = qualifiedHost.split(":");
- if ( address.length>0 && isNotBlank(address[0]) ){
- return address[0];
- }
- }
- //endregion
- throw new URISyntaxException( qualifiedHost , "invalid hostname, expecting a single <host:port> , (valid ex. www.google.com:80 | www.google.com | http:\\\\www.google.com:8181)");
}
}