This closes #2664

artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/NettyConnection.java

@@ -137,10 +137,15 @@ public class NettyConnection implements Connection {
             readyListeners.add(callback);
          }
 
-         return ready && channel.isOpen();
+         return ready;
       }
    }
 
+   @Override
+   public boolean isOpen() {
+      return channel.isOpen();
+   }
+
    @Override
    public final void fireReady(final boolean ready) {
       ArrayList<ReadyListener> readyToCall = localListenersPool.get();

artemis-core-client/src/main/java/org/apache/activemq/artemis/spi/core/remoting/Connection.java

@@ -43,6 +43,8 @@ public interface Connection {
 
    boolean isWritable(ReadyListener listener);
 
+   boolean isOpen();
+
    /**
     * Causes the current thread to wait until the connection can enqueue the required capacity unless the specified waiting time elapses.
     * The available capacity of the connection could change concurrently hence this method is suitable to perform precise flow-control

artemis-core-client/src/test/java/org/apache/activemq/artemis/core/protocol/core/impl/ChannelImplTest.java

@@ -343,6 +343,11 @@ public class ChannelImplTest {
 
             }
 
+            @Override
+            public boolean isOpen() {
+               return true;
+            }
+
             @Override
             public boolean isWritable(ReadyListener listener) {
                return false;

artemis-protocols/artemis-stomp-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/stomp/StompConnection.java

@@ -153,7 +153,7 @@ public final class StompConnection implements RemotingConnection {
 
    @Override
    public boolean isWritable(ReadyListener callback) {
-      return transportConnection.isWritable(callback);
+      return transportConnection.isWritable(callback) && transportConnection.isOpen();
    }
 
    public boolean hasBytes() {

artemis-server/src/main/java/org/apache/activemq/artemis/core/remoting/impl/invm/InVMConnection.java

@@ -116,6 +116,11 @@ public class InVMConnection implements Connection {
       return true;
    }
 
+   @Override
+   public boolean isOpen() {
+      return true;
+   }
+
    @Override
    public void fireReady(boolean ready) {
    }