summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java5
1 files changed, 4 insertions, 1 deletions
diff --git a/src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java b/src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java
index 02ae109..63f1dd5 100644
--- a/src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java
+++ b/src/main/java/com/att/nsa/cambria/beans/DMaaPKafkaConsumerFactory.java
@@ -111,7 +111,10 @@ public class DMaaPKafkaConsumerFactory implements ConsumerFactory {
// kSetting_EnableCache, kDefault_IsCacheEnabled);
boolean kSetting_EnableCache= kDefault_IsCacheEnabled;
String strkSetting_EnableCache = AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,kSetting_EnableCache+"");
- if(null!=strkSetting_EnableCache)kSetting_EnableCache=Boolean.parseBoolean(strkSetting_EnableCache);
+ if(null!=strkSetting_EnableCache)
+ {
+ kSetting_EnableCache=Boolean.parseBoolean(strkSetting_EnableCache);
+ }
final boolean isCacheEnabled = kSetting_EnableCache;