diff options
author | 2018-04-09 23:32:49 +0000 | |
---|---|---|
committer | 2018-04-09 23:32:49 +0000 | |
commit | cd7d8f5c03d633ab2c2bafbb55f5170cf9940a11 (patch) | |
tree | 88ee231ad41e26cff00f7c3948a5b275280e171f /src/main/java/com | |
parent | 5b088ab5fab5dc7c475f3e30b3b0df1535b67564 (diff) | |
parent | 3fb3ced55e83e626a6f2196fbb75a6d392d5292e (diff) |
Merge "sonar critical for errorhandling"
Diffstat (limited to 'src/main/java/com')
-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); } |