summaryrefslogtreecommitdiffstats
path: root/catalog-be/src/main/java/org/openecomp/sdc/be/catalog/impl/DmaapProducerHealth.java
diff options
context:
space:
mode:
Diffstat (limited to 'catalog-be/src/main/java/org/openecomp/sdc/be/catalog/impl/DmaapProducerHealth.java')
-rw-r--r--catalog-be/src/main/java/org/openecomp/sdc/be/catalog/impl/DmaapProducerHealth.java6
1 files changed, 0 insertions, 6 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/catalog/impl/DmaapProducerHealth.java b/catalog-be/src/main/java/org/openecomp/sdc/be/catalog/impl/DmaapProducerHealth.java
index 4000be39b3..c0150fa3cb 100644
--- a/catalog-be/src/main/java/org/openecomp/sdc/be/catalog/impl/DmaapProducerHealth.java
+++ b/catalog-be/src/main/java/org/openecomp/sdc/be/catalog/impl/DmaapProducerHealth.java
@@ -43,7 +43,6 @@ public class DmaapProducerHealth {
private static final Logger logHealth = Logger.getLogger(DMAAP_HEALTH_LOG_CONTEXT);
private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
private HealthCheckInfo healthCheckInfo = DmaapProducerHealth.HealthCheckInfoResult.UNAVAILABLE.getHealthCheckInfo();
- private long healthCheckReadTimeout = 20;
private long reconnectInterval = 5;
private HealthCheckScheduledTask healthCheckScheduledTask = null;
private ScheduledFuture<?> scheduledFuture = null;
@@ -60,10 +59,6 @@ public class DmaapProducerHealth {
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
startHealthCheckTask(true);
}
@@ -149,7 +144,6 @@ public class DmaapProducerHealth {
*/
public class HealthCheckScheduledTask implements Runnable {
- private static final int TIMEOUT = 8192;
private final DmaapProducerConfiguration config;
HealthCheckScheduledTask(final DmaapProducerConfiguration config) {