#7256 close channel underlying the queue's filelock

Fixes #7257
This commit is contained in:
Armin 2017-05-29 23:35:12 +02:00 committed by Armin Braun
parent fe58408a2e
commit b1d8a4b2e3

View file

@ -114,6 +114,7 @@ public class FileLockFactory {
String lockPath = LOCK_MAP.remove(lock);
if (lockPath == null) { throw new LockException("Cannot release unobtained lock"); }
lock.release();
lock.channel().close();
Boolean removed = LOCK_HELD.remove(lockPath);
if (removed == false) { throw new LockException("Lock path was not marked as held: " + lockPath); }
}