From 73e8bdf78e87ee9e5cdd92b1f085ae8255b252aa Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 14 Mar 2007 16:05:50 +0000 Subject: Recorded rollback of revisions 492756 via svnmerge from https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@518198 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/server/protocol/AMQMinaProtocolSession.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'java') diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java index 6b88d605e1..b641579376 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java +++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java @@ -253,14 +253,14 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, String locales = "en_US"; // Interfacing with generated code - be aware of possible changes to parameter order as versions change. - AMQFrame response = ConnectionStartBody.createAMQFrame((short) 0, - _major, _minor, // AMQP version (major, minor) + AMQMethodBody connectionStartBody = ConnectionStartBody.createMethodBody + ((byte)_major, (byte)_minor, // AMQP version (major, minor) locales.getBytes(), // locales mechanisms.getBytes(), // mechanisms null, // serverProperties (short)_major, // versionMajor (short)_minor); // versionMinor - _minaProtocolSession.write(response); + writeRequest(0, connectionStartBody, _stateManager); } catch (AMQException e) { -- cgit v1.2.1