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, 3 deletions

diff --git a/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java b/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java
index da3d0a2c56..5b6a8e3ef7 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/ConnectionStartOkBody.java
@@ -126,7 +126,7 @@ public class ConnectionStartOkBody extends AMQMethodBodyImpl implements Encodabl
         return buf.toString();
     }
 
-    public static void process(final MarkableDataInput in, final MethodProcessor dispatcher)
+    public static void process(final MarkableDataInput in, final ServerMethodProcessor dispatcher)
             throws IOException, AMQFrameDecodingException
     {
 
@@ -134,7 +134,9 @@ public class ConnectionStartOkBody extends AMQMethodBodyImpl implements Encodabl
         AMQShortString mechanism = in.readAMQShortString();
         byte[] response = EncodingUtils.readBytes(in);
         AMQShortString locale = in.readAMQShortString();
-
-        dispatcher.receiveConnectionStartOk(clientProperties, mechanism, response, locale);
+        if(!dispatcher.ignoreAllButCloseOk())
+        {
+            dispatcher.receiveConnectionStartOk(clientProperties, mechanism, response, locale);
+        }
     }
 }