diff --git a/src/main/java/org/taktik/mpegts/Streamer.java b/src/main/java/org/taktik/mpegts/Streamer.java index 9aeb47ca..ccc0a515 100644 --- a/src/main/java/org/taktik/mpegts/Streamer.java +++ b/src/main/java/org/taktik/mpegts/Streamer.java @@ -77,8 +77,12 @@ public class Streamer { log.error("Couldn't close sink", e); } buffer.clear(); - bufferingThread.interrupt(); - streamingThread.interrupt(); + try { + bufferingThread.interrupt(); + streamingThread.interrupt(); + } catch (Exception e) { + log.error("Couldn't interrupt streamer threads"); + } } private void internalStream() {