summaryrefslogtreecommitdiffstats
path: root/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'src/main')
-rw-r--r--src/main/java/com/att/nsa/cambria/resources/CambriaOutboundEventStream.java5
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();
}
}
});