summaryrefslogtreecommitdiffstats
path: root/src/main/java/com/att/nsa
diff options
context:
space:
mode:
authorDushyant Singh Thakur <dt00503496@techmahindra.com>2018-03-28 15:19:38 +0530
committerDushyant Singh Thakur <dt00503496@techmahindra.com>2018-03-28 15:19:38 +0530
commit3fb3ced55e83e626a6f2196fbb75a6d392d5292e (patch)
tree49e31e7d832e47fe0c0ed7d42d9ddb4aaab82ea2 /src/main/java/com/att/nsa
parent460b2066308869e50f7b5320726780676d0d1f05 (diff)
sonar critical for errorhandling
Either re-interrupt this method or rethrow the InterruptedException Sonar Link: https://sonar.onap.org/project/issues?id=org.onap.dmaap.messagerouter.msgrtr%3Amsgrtr&open=AV4-Vagy32hFUzlqc5s0&resolved=false&severities=CRITICAL&types=BUG Location: src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java Line No-192 Change-Id: I5cdf566045392cb5845067565c50660b2afed333 Issue-ID: DMAAP-307 Signed-off-by: Dushyant Singh Thakur <dt00503496@techmahindra.com>
Diffstat (limited to 'src/main/java/com/att/nsa')
-rw-r--r--src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java b/src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java
index 052cc78..d7e6816 100644
--- a/src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java
+++ b/src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java
@@ -190,7 +190,8 @@ public class DMaaPCambriaSimplerBatchPublisher extends CambriaBaseClient
+ "Consider using CambriaBatchingPublisher.close( long timeout, TimeUnit timeoutUnits ) to recapture unsent messages on close.");
}
} catch (InterruptedException e) {
- getLog().warn("Possible message loss. " + e.getMessage(), e);
+ getLog().info(" Interruption Exception is caught here : " + e.getMessage());
+ Thread.currentThread().interrupt();
} catch (IOException e) {
getLog().warn("Possible message loss. " + e.getMessage(), e);
}