1 files changed, 7 insertions, 5 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenOkBody.java b/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenOkBody.java
index 775a08fbd4..e3b4f38a8c 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenOkBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenOkBody.java
@@ -96,16 +96,18 @@ public class ChannelOpenOkBody extends AMQMethodBodyImpl implements EncodableAMQ
         return "[ChannelOpenOkBody]";
     }
 
-    public static void process(final int channelId,
-                                final MarkableDataInput in,
-                                final ProtocolVersion protocolVersion,
-                                final MethodProcessor dispatcher) throws IOException
+    public static void process(final MarkableDataInput in,
+                               final ProtocolVersion protocolVersion,
+                               final ClientChannelMethodProcessor dispatcher) throws IOException
     {
         if(!ProtocolVersion.v8_0.equals(protocolVersion))
         {
             EncodingUtils.readBytes(in);
         }
 
-        dispatcher.receiveChannelOpenOk(channelId);
+        if(!dispatcher.ignoreAllButCloseOk())
+        {
+            dispatcher.receiveChannelOpenOk();
+        }
     }
 }