diff options
Diffstat (limited to 'java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java')
-rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java | 9 |
1 files changed, 4 insertions, 5 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 5cf767ac35..3bb5707417 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,11 +30,9 @@ 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 @@ -64,12 +62,12 @@ public class QpidConnectionMetaData implements ConnectionMetaData public int getProviderMajorVersion() throws JMSException { - return con.getProtocolVersion().getMajorVersion(); + return 0; } public int getProviderMinorVersion() throws JMSException { - return con.getProtocolVersion().getMinorVersion(); + return 8; } public String getProviderVersion() throws JMSException @@ -80,7 +78,8 @@ public class QpidConnectionMetaData implements ConnectionMetaData private String getProtocolVersion() { - return con.getProtocolVersion().toString(); + // TODO - Implement based on connection negotiated protocol + return "0.8"; } public String getBrokerVersion() |