From 62c172a8178793fa44f590ce5b3d072302c7a450 Mon Sep 17 00:00:00 2001 From: Robert Greig Date: Wed, 7 Feb 2007 23:30:22 +0000 Subject: Added a system property qpid.accept.broker.version to allow the client to accept whatever version the broker offers on connection negotiation. Useful when testing different broker implementations that may not be in sync with Qpid versioning. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@504736 13f79535-47bb-0310-9956-ffa450edef68 --- .../handler/ConnectionStartMethodHandler.java | 25 +++++++++++++++------- 1 file changed, 17 insertions(+), 8 deletions(-) (limited to 'qpid/java/client') diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionStartMethodHandler.java b/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionStartMethodHandler.java index 66fa9de92c..1dd9df0088 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionStartMethodHandler.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/handler/ConnectionStartMethodHandler.java @@ -63,7 +63,7 @@ public class ConnectionStartMethodHandler implements StateAwareMethodListener byte major = (byte) body.versionMajor; byte minor = (byte) body.versionMinor; - if(checkVersionOK(major, minor)) + if (checkVersionOK(major, minor)) { protocolSession.setProtocolVersion(major, minor); @@ -169,16 +169,25 @@ public class ConnectionStartMethodHandler implements StateAwareMethodListener private boolean checkVersionOK(byte versionMajor, byte versionMinor) { - byte[][] supportedVersions = ProtocolVersionList.pv; - boolean supported = false; - int i = supportedVersions.length; - while(i-- != 0 && !supported) + // this system property allows the client to accept whatever version the broker + // offers. Useful only when doing testing. + if (Boolean.getBoolean("qpid.accept.broker.version")) { - supported = (supportedVersions[i][ProtocolVersionList.PROTOCOL_MAJOR] == versionMajor) - && (supportedVersions[i][ProtocolVersionList.PROTOCOL_MINOR] == versionMinor); + return true; } + else + { + byte[][] supportedVersions = ProtocolVersionList.pv; + boolean supported = false; + int i = supportedVersions.length; + while(i-- != 0 && !supported) + { + supported = (supportedVersions[i][ProtocolVersionList.PROTOCOL_MAJOR] == versionMajor) + && (supportedVersions[i][ProtocolVersionList.PROTOCOL_MINOR] == versionMinor); + } - return supported; + return supported; + } } private String getFullSystemInfo() -- cgit v1.2.1