This commit is contained in:
@@ -107,7 +107,11 @@ public abstract class AsyncConnection implements AsynchronousByteChannel, AutoCl
|
|||||||
livingCounter.decrementAndGet();
|
livingCounter.decrementAndGet();
|
||||||
livingCounter = null;
|
livingCounter = null;
|
||||||
}
|
}
|
||||||
if (beforeCloseListener != null) beforeCloseListener.accept(this);
|
if (beforeCloseListener != null)
|
||||||
|
try {
|
||||||
|
beforeCloseListener.accept(this);
|
||||||
|
} catch (Exception io) {
|
||||||
|
}
|
||||||
if (attributes == null) return;
|
if (attributes == null) return;
|
||||||
try {
|
try {
|
||||||
for (Object obj : attributes.values()) {
|
for (Object obj : attributes.values()) {
|
||||||
|
|||||||
Reference in New Issue
Block a user