MINOR: Fix dlq reader not closing its watchservice

Fixes #8276
This commit is contained in:
Armin 2017-09-15 17:19:33 +02:00 committed by Armin Braun
parent d9ba3463b3
commit 912a84c9fe

View file

@ -159,5 +159,6 @@ public final class DeadLetterQueueReader implements Closeable {
if (currentReader != null) {
currentReader.close();
}
this.watchService.close();
}
}