diff options
Diffstat (limited to 'java/common')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpidity/transport/ConnectionDelegate.java | 2 | ||||
| -rw-r--r-- | java/common/src/main/java/org/apache/qpidity/transport/TransportConstants.java | 7 |
2 files changed, 8 insertions, 1 deletions
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<Channel> 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; +} |
