From bcaf7ab73ead61ceb3839a661befb548d844392e Mon Sep 17 00:00:00 2001
From: Redkale <8730487+redkale@users.noreply.github.com>
Date: Fri, 18 Jan 2019 19:48:32 +0800
Subject: [PATCH]

---
 src/org/redkale/net/TcpAioAsyncConnection.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/org/redkale/net/TcpAioAsyncConnection.java b/src/org/redkale/net/TcpAioAsyncConnection.java
index 703f599bd..6d69919cd 100644
--- 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 {