From: Surendra Reddy Katam <SK00524980@techmahindra.com>
Date: Thu, 12 Apr 2018 06:07:47 +0000 (+0530)
Subject: Sonar critical issues
X-Git-Tag: v1.1.4~9
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=a6c30bf53e5a7241d310e6579af7f0705b303329;p=dmaap%2Fmessagerouter%2Fmsgrtr.git

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>
---

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();
 		}
 	}