diff options
| author | Rajith Muditha Attapattu <rajith@apache.org> | 2011-06-22 03:39:53 +0000 |
|---|---|---|
| committer | Rajith Muditha Attapattu <rajith@apache.org> | 2011-06-22 03:39:53 +0000 |
| commit | 50f2b60a98544606d2e20da8e211d04a959831ee (patch) | |
| tree | a5cdf31059be45058542df3ad1f50cd77779502b /java | |
| parent | 4ce88fd57f8d1a55cf6aab121597a0d481adf9f5 (diff) | |
| download | qpid-python-50f2b60a98544606d2e20da8e211d04a959831ee.tar.gz | |
QPID-3270 The protocol version is now read from the Connection object
passed into when creating the ConnectionMetaData.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1138295 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java b/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java index 3bb5707417..5cf767ac35 100644 --- a/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java +++ b/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java @@ -30,9 +30,11 @@ import org.apache.qpid.common.QpidProperties; public class QpidConnectionMetaData implements ConnectionMetaData { + private AMQConnection con; QpidConnectionMetaData(AMQConnection conn) { + this.con = conn; } public int getJMSMajorVersion() throws JMSException @@ -62,12 +64,12 @@ public class QpidConnectionMetaData implements ConnectionMetaData public int getProviderMajorVersion() throws JMSException { - return 0; + return con.getProtocolVersion().getMajorVersion(); } public int getProviderMinorVersion() throws JMSException { - return 8; + return con.getProtocolVersion().getMinorVersion(); } public String getProviderVersion() throws JMSException @@ -78,8 +80,7 @@ public class QpidConnectionMetaData implements ConnectionMetaData private String getProtocolVersion() { - // TODO - Implement based on connection negotiated protocol - return "0.8"; + return con.getProtocolVersion().toString(); } public String getBrokerVersion() |