X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fcom%2Fatt%2Fnsa%2Fcambria%2Fbackends%2Fkafka%2FKafkaConsumerCache.java;h=9bd67d17ed04fd8806ec0891366bff9c8153dc25;hb=0823cb186012c8e6b7de3d979dfabb9f838da7c2;hp=2a6498951458e40a6f4de83b27770af47f8493ab;hpb=fbf480fc5e72d3a392a08250a6edfbe3ed6920ff;p=dmaap%2Fmessagerouter%2Fmsgrtr.git

diff --git a/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java b/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java
index 2a64989..9bd67d1 100644
--- a/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java
+++ b/src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java
@@ -46,7 +46,7 @@ import org.apache.curator.utils.ZKPaths;
 import org.apache.http.annotation.NotThreadSafe;
 import org.apache.zookeeper.KeeperException;
 import org.apache.zookeeper.KeeperException.NoNodeException;
-//import org.slf4j.Logger;
+
 //import org.slf4j.LoggerFactory;
 import com.att.eelf.configuration.EELFLogger;
 import com.att.eelf.configuration.EELFManager;
@@ -239,7 +239,9 @@ public class KafkaConsumerCache {
 			//final long freq = fSettings.getLong(kSetting_SweepEverySeconds, kDefault_SweepEverySeconds);
 			long freq = kDefault_SweepEverySeconds;
 			String strkSetting_SweepEverySeconds = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,kSetting_SweepEverySeconds);
-			if(null==strkSetting_SweepEverySeconds) strkSetting_SweepEverySeconds = kDefault_SweepEverySeconds+"";
+			if(null==strkSetting_SweepEverySeconds) {
+				strkSetting_SweepEverySeconds = kDefault_SweepEverySeconds+"";
+			}
 			
 			  freq = Long.parseLong(strkSetting_SweepEverySeconds);