Migrate broker to new direct method dispatch mechanism

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6125-ProtocolRefactoring@1631275 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 5 insertions, 2 deletions

diff --git a/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenBody.java b/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenBody.java
index 9da45d3d70..af583f5fda 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/ChannelOpenBody.java
@@ -84,9 +84,12 @@ public class ChannelOpenBody extends AMQMethodBodyImpl implements EncodableAMQDa
 
     public static void process(final int channelId,
                                 final MarkableDataInput buffer,
-                                final MethodProcessor dispatcher) throws IOException
+                                final ServerMethodProcessor dispatcher) throws IOException
     {
         buffer.readAMQShortString();
-        dispatcher.receiveChannelOpen(channelId);
+        if(!dispatcher.ignoreAllButCloseOk())
+        {
+            dispatcher.receiveChannelOpen(channelId);
+        }
     }
 }