summaryrefslogtreecommitdiff
path: root/java/broker/src
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2007-03-14 16:05:50 +0000
committerAlan Conway <aconway@apache.org>2007-03-14 16:05:50 +0000
commit73e8bdf78e87ee9e5cdd92b1f085ae8255b252aa (patch)
treeb74a1d6a56b26dc934d564350bab4c5007ce3eef /java/broker/src
parentf627ac7ef1c409275b73f5f330da260fe90ad64b (diff)
downloadqpid-python-73e8bdf78e87ee9e5cdd92b1f085ae8255b252aa.tar.gz
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
Diffstat (limited to 'java/broker/src')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java6
1 files changed, 3 insertions, 3 deletions
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)
{