diff options
| author |   Surendra Reddy Katam <SK00524980@techmahindra.com> | 2018-04-12 11:37:47 +0530 |
|---|---|---|
| committer | Surendra Reddy Katam <SK00524980@techmahindra.com> | 2018-04-12 11:37:47 +0530 |
| commit | a6c30bf53e5a7241d310e6579af7f0705b303329 (patch) | |
| tree | bb09060a4b65f46dba6447f3b096102eb7f284fa | |
| parent | 860241166797e6a559618e4d55e7d0388c4273a6 (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>
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/backends/kafka/KafkaConsumerCache.java | 3 |
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(); } } |