diff options
| author |   Surendra Reddy Katam <SK00524980@techmahindra.com> | 2018-04-17 13:14:34 +0530 |
|---|---|---|
| committer | Surendra Reddy Katam <SK00524980@techmahindra.com> | 2018-04-17 13:14:34 +0530 |
| commit | e7954efb84ebdef62ac524e7960a7fa66fecdfc7 (patch) | |
| tree | 7d2684330fb11fdf3e0439c32ef750276a15931b /src/main/java/com/att/nsa | |
| parent | 2baebaa9396eca7d94481b9191daf4ef62a254ab (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-VahN32hFUzlqc5tz&resolved=false&severities=CRITICAL
Location:
src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java
Line No-329
Change-Id: If36c06fc3fbfd94a455e90b2c1f5c12ed7575eb4
Issue-ID: DMAAP-417
Signed-off-by: Surendra Reddy Katam <SK00524980@techmahindra.com>
Diffstat (limited to 'src/main/java/com/att/nsa')
| -rw-r--r-- | src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java b/src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java index e519f71..7366dde 100644 --- a/src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java +++ b/src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java @@ -44,6 +44,8 @@ import com.att.nsa.cambria.metabroker.Topic; import com.att.nsa.cambria.utils.DMaaPResponseBuilder.StreamWriter; import com.att.nsa.cambria.utils.Utils; +import jline.internal.Log; + /** * class used to write the consumed messages @@ -327,7 +329,8 @@ public class CambriaOutboundEventStream implements StreamWriter { // FIXME: would be good to wait/signal Thread.sleep(100); } catch (InterruptedException e) { - // ignore + Log.error(e.toString()); + Thread.currentThread().interrupt(); } } }); |