summaryrefslogtreecommitdiffstats
path: root/src/main/java
diff options
context:
space:
mode:
authorSurendra Reddy Katam <SK00524980@techmahindra.com>2018-04-12 11:37:47 +0530
committerSurendra Reddy Katam <SK00524980@techmahindra.com>2018-04-12 11:37:47 +0530
commita6c30bf53e5a7241d310e6579af7f0705b303329 (patch)
treebb09060a4b65f46dba6447f3b096102eb7f284fa /src/main/java
parent860241166797e6a559618e4d55e7d0388c4273a6 (diff)
Sonar critical issues
Either re-interrupt this method or rethrow the InterruptedException Sonar Link: https://sonar.onap.org/project/issues?assignees=surendraReddy&id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr&open=AV4-VabL32hFUzlqc5nF&resolved=false&severities=CRITICAL Location: src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java Line No-543 Change-Id: I55e02be114874ba791d7caf72665d4a655fa833b Issue-ID: DMAAP-406 Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
Diffstat (limited to 'src/main/java')
-rw-r--r--src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java3
1 files changed, 2 insertions, 1 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 ea38273..a9d0d9b 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
@@ -542,7 +542,8 @@ public class KafkaConsumerCache {
Thread.sleep(kSetting_ConsumerHandoverWaitMs);
//Thread.sleep(fSettings.getInt(kSetting_ConsumerHandoverWaitMs, kDefault_ConsumerHandoverWaitMs));
} catch (InterruptedException e) {
- // Ignore
+ log.error(e.toString());
+ Thread.currentThread().interrupt();
}
}