From 1c1efeddef24ef18d75af65e4249b541b1382ea8 Mon Sep 17 00:00:00 2001 From: Rajith Muditha Attapattu Date: Thu, 13 Mar 2008 16:04:46 +0000 Subject: Added constant to represent the AMQP versions, as previously it was hard-coded. Modified the ConnectionDelegate to use the Constants for AMQP version. Also the version cosntants were changed to 99-0 to work with the c++ broker until the 0-10 framing gets completed. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@636791 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpidity/transport/ConnectionDelegate.java | 2 +- .../main/java/org/apache/qpidity/transport/TransportConstants.java | 7 +++++++ 2 files changed, 8 insertions(+), 1 deletion(-) create mode 100644 java/common/src/main/java/org/apache/qpidity/transport/TransportConstants.java diff --git a/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java b/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java index 001ad7220c..21c7b8c16b 100644 --- a/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java +++ b/java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java @@ -83,7 +83,7 @@ public abstract class ConnectionDelegate extends MethodDelegate if (hdr.getMajor() != 0 && hdr.getMinor() != 10) { // XXX - ch.getConnection().send(new ConnectionEvent(0, new ProtocolHeader(1, 0, 10))); + ch.getConnection().send(new ConnectionEvent(0, new ProtocolHeader(1, TransportConstants.CONNECTION_VERSION_MAJOR, TransportConstants.CONNECTION_VERSION_MINOR))); ch.getConnection().close(); } else diff --git a/java/common/src/main/java/org/apache/qpidity/transport/TransportConstants.java b/java/common/src/main/java/org/apache/qpidity/transport/TransportConstants.java new file mode 100644 index 0000000000..47f7f17578 --- /dev/null +++ b/java/common/src/main/java/org/apache/qpidity/transport/TransportConstants.java @@ -0,0 +1,7 @@ +package org.apache.qpidity.transport; + +public class TransportConstants +{ + public static final byte CONNECTION_VERSION_MAJOR = 99; + public static final byte CONNECTION_VERSION_MINOR = 0; +} -- cgit v1.2.1