diff options
| author |   Ram Koya <rk541m@att.com> | 2018-05-09 17:56:56 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-05-09 17:56:56 +0000 |
| commit | 0823cb186012c8e6b7de3d979dfabb9f838da7c2 (patch) | |
| tree | c419c8745f64d4079ab8c9cf2b52852a239ddbc2 | |
| parent | e0939f596aa0598581639b5e90d9c8d8264173a7 (diff) | |
| parent | fbf480fc5e72d3a392a08250a6edfbe3ed6920ff (diff) | |
Merge "sonar critical for Conditional Statement"2.0.0-ONAPbeijing2.0.0-ONAP
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java | 5 |
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) { |