2019-01-18 19:48:32 +08:00
parent b9d7eaee1b
commit bcaf7ab73e
1 changed files with 1 additions and 1 deletions
--- a/src/org/redkale/net/TcpAioAsyncConnection.java
+++ b/src/org/redkale/net/TcpAioAsyncConnection.java
@@ -112,7 +112,7 @@ public class TcpAioAsyncConnection extends AsyncConnection {

    private <A> void nextWrite(Throwable exc, A attachment) {
        BlockingQueue<WriteEntry> queue = this.writeQueue;
-        if (exc != null && !isOpen()) {
+        if (queue != null && exc != null && !isOpen()) {
            WriteEntry entry;
            while ((entry = queue.poll()) != null) {
                try {