diff options
| author |   Dushyant Singh Thakur <dt00503496@techmahindra.com> | 2018-03-28 15:19:38 +0530 |
|---|---|---|
| committer | Dushyant Singh Thakur <dt00503496@techmahindra.com> | 2018-03-28 15:19:38 +0530 |
| commit | 3fb3ced55e83e626a6f2196fbb75a6d392d5292e (patch) | |
| tree | 49e31e7d832e47fe0c0ed7d42d9ddb4aaab82ea2 /src/main/java/com/att/nsa/cambria/metrics/publisher | |
| parent | 460b2066308869e50f7b5320726780676d0d1f05 (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/cambria/metrics/publisher')
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/metrics/publisher/impl/DMaaPCambriaSimplerBatchPublisher.java | 3 |
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); } |