1 files changed, 4 insertions, 3 deletions
diff --git a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java
index 6e2a6cac7d..7f646b43b4 100644
--- a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java
+++ b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnectionDelegate.java
@@ -250,7 +250,7 @@ public class ServerConnectionDelegate extends ServerDelegate
                     ") above the server's offered limit (" + getChannelMax() +")");
 
             //Due to the error we must forcefully close the connection without negotiation
-            sconn.getSender().close();
+            sconn.closeAndIgnoreFutureInput();
             return;
         }
 
@@ -261,7 +261,8 @@ public class ServerConnectionDelegate extends ServerDelegate
                          ") above the server's offered limit (" + getFrameMax() +")");
 
             //Due to the error we must forcefully close the connection without negotiation
-            sconn.getSender().close();
+            sconn.closeAndIgnoreFutureInput();
+
             return;
         }
         else if(okMaxFrameSize > 0 && okMaxFrameSize < Constant.MIN_MAX_FRAME_SIZE)
@@ -271,7 +272,7 @@ public class ServerConnectionDelegate extends ServerDelegate
                          ") below the minimum permitted size (" + Constant.MIN_MAX_FRAME_SIZE +")");
 
             //Due to the error we must forcefully close the connection without negotiation
-            sconn.getSender().close();
+            sconn.closeAndIgnoreFutureInput();
             return;
         }
         else if(okMaxFrameSize == 0)