diff --git a/src/main/java/com/pivovarit/collectors/Dispatcher.java b/src/main/java/com/pivovarit/collectors/Dispatcher.java index 6aaa0e43..f78742ee 100644 --- a/src/main/java/com/pivovarit/collectors/Dispatcher.java +++ b/src/main/java/com/pivovarit/collectors/Dispatcher.java @@ -65,6 +65,7 @@ void start() { task.run(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); + handle(e); throw new RuntimeException(e); } finally { limiter.release();