Commit bcef6d06 authored by Nelson Tavares de Sousa's avatar Nelson Tavares de Sousa

fixes #292

parent faf2c86e
......@@ -166,9 +166,12 @@ class ThreadService extends AbstractService<ThreadService> { // NOPMD
}
}
LOGGER.debug("Interrupting infiniteProducerThreads...");
for (Thread thread : this.infiniteProducerThreads) {
thread.interrupt();
if (!this.infiniteProducerThreads.isEmpty()) {
LOGGER.debug("Interrupting infiniteProducerThreads...");
for (Thread thread : this.infiniteProducerThreads) {
thread.interrupt();
}
LOGGER.debug("infiniteProducerThreads have been terminated");
}
// List<Exception> exceptions = collectExceptions();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment