diff options
| author |   Ram Koya <rk541m@att.com> | 2018-04-27 15:43:03 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@onap.org> | 2018-04-27 15:43:03 +0000 |
| commit | 0ee32170163c467c88e35f2ec019df486b9f4c33 (patch) | |
| tree | 2de01913f974050d9ebb12ae641edddaf3098cf5 /src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java | |
| parent | fd43f0cffba3a74ad6962d931dda738eda16e99c (diff) | |
| parent | e25f2025171ba6f9f2f3fddc76cee021bf86c9d1 (diff) | |
Merge changes I624da3f9,I5e879cf1,I43199346,I124eefbc,If36c06fcv1.1.4
* changes:
Sonar critical issues
Sonar critical issues
Sonar critical issues
Sonar critical issues
Sonar critical issues
Diffstat (limited to 'src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java')
| -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(); } } }); |