From 483dd37a5decdcf489c4f1b7eaf249c314125b3a Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 9 Mar 2007 17:57:40 +0000 Subject: Merged revisions 492756 via svnmerge from https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid ........ r492756 | kpvdr | 2007-01-04 16:30:39 -0500 (Thu, 04 Jan 2007) | 1 line Fixed C++ client sending protocol version 0-0 over the wire. Minor fixes and tidy-up in related code. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@516485 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/server/protocol/AMQMinaProtocolSession.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 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 55edea4bbb..6b88d605e1 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. - 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 - writeRequest(0, connectionStartBody, _stateManager); + AMQFrame response = ConnectionStartBody.createAMQFrame((short) 0, + _major, _minor, // AMQP version (major, minor) + locales.getBytes(), // locales + mechanisms.getBytes(), // mechanisms + null, // serverProperties + (short)_major, // versionMajor + (short)_minor); // versionMinor + _minaProtocolSession.write(response); } catch (AMQException e) { -- cgit v1.2.1