summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att/nsa
diff options
context:
space:
mode:
authorRam Koya <rk541m@att.com>2018-05-09 17:56:56 +0000
committerGerrit Code Review <gerrit@onap.org>2018-05-09 17:56:56 +0000
commit0823cb186012c8e6b7de3d979dfabb9f838da7c2 (patch)
treec419c8745f64d4079ab8c9cf2b52852a239ddbc2 /src/main/java/com/att/nsa
parente0939f596aa0598581639b5e90d9c8d8264173a7 (diff)
parentfbf480fc5e72d3a392a08250a6edfbe3ed6920ff (diff)
Merge "sonar critical for Conditional Statement"2.0.0-ONAPbeijing2.0.0-ONAP
Diffstat (limited to 'src/main/java/com/att/nsa')
-rw-r--r--src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java5
1 files changed, 3 insertions, 2 deletions
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 0d6a74e..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
@@ -539,8 +539,9 @@ public class KafkaConsumerCache {
try {
int kSetting_ConsumerHandoverWaitMs = kDefault_ConsumerHandoverWaitMs;
String strkSetting_ConsumerHandoverWaitMs= AJSCPropertiesMap.getProperty(CambriaConstants.msgRtr_prop,kSetting_ConsumerHandoverWaitMs+"");
- if(strkSetting_ConsumerHandoverWaitMs!=null) kSetting_ConsumerHandoverWaitMs = Integer.parseInt(strkSetting_ConsumerHandoverWaitMs);
-
+ if(strkSetting_ConsumerHandoverWaitMs!=null) {
+ kSetting_ConsumerHandoverWaitMs = Integer.parseInt(strkSetting_ConsumerHandoverWaitMs);
+ }
Thread.sleep(kSetting_ConsumerHandoverWaitMs);
//Thread.sleep(fSettings.getInt(kSetting_ConsumerHandoverWaitMs, kDefault_ConsumerHandoverWaitMs));
} catch (InterruptedException e) {