diff options
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.java | 6 |
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) { |