summaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
authorSaurabh Kumar26 <sk00552209@techmahindra.com>2018-05-07 16:29:29 +0530
committerSaurabh Kumar26 <sk00552209@techmahindra.com>2018-05-07 16:29:29 +0530
commitfbf480fc5e72d3a392a08250a6edfbe3ed6920ff (patch)
treedc3799ea21c3d55eb76772d10f293619e1851951 /src/main/java
parent0ee32170163c467c88e35f2ec019df486b9f4c33 (diff)
sonar critical for Conditional Statement
added '{}' after if statement Sonar Link: https://sonar.onap.org/project/issues?assignees=SaurabhKumar26&id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr&resolved=false&severities=CRITICAL Location: src/.../att/nsa/cambria/backends/kafka/KafkaConsumerCache.java Line No. 542 Change-Id: I811432fc77002d49c374f070e3438ed88bc0eb16 Issue-ID: DMAAP-469 Signed-off-by: Saurabh Kumar26 <sk00552209@techmahindra.com>
Diffstat (limited to 'src/main/java')
-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 a9d0d9b..2a64989 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
@@ -537,8 +537,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) {