You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ra...@apache.org on 2011/06/22 05:39:53 UTC
svn commit: r1138295 -
/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java
Author: rajith
Date: Wed Jun 22 03:39:53 2011
New Revision: 1138295
URL: http://svn.apache.org/viewvc?rev=1138295&view=rev
Log:
QPID-3270 The protocol version is now read from the Connection object
passed into when creating the ConnectionMetaData.
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java
Modified: qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java?rev=1138295&r1=1138294&r2=1138295&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java (original)
+++ qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/QpidConnectionMetaData.java Wed Jun 22 03:39:53 2011
@@ -30,9 +30,11 @@ import org.apache.qpid.common.QpidProper
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 impl
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 impl
private String getProtocolVersion()
{
- // TODO - Implement based on connection negotiated protocol
- return "0.8";
+ return con.getProtocolVersion().toString();
}
public String getBrokerVersion()
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org