2 files changed, 21 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
index 9bded39af4..4717a9495b 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQConnectionDelegate_0_10.java
@@ -398,4 +398,9 @@ public class AMQConnectionDelegate_0_10 implements AMQConnectionDelegate, Connec
         } 
         return 0;
     }
+    
+    protected org.apache.qpid.transport.Connection getQpidConnection()
+    {
+        return _qpidConnection;
+    }
 }
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQTestConnection_0_10.java b/java/client/src/main/java/org/apache/qpid/client/AMQTestConnection_0_10.java
new file mode 100644
index 0000000000..540b6042bf
--- /dev/null
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQTestConnection_0_10.java
@@ -0,0 +1,16 @@
+package org.apache.qpid.client;
+
+import org.apache.qpid.transport.Connection;
+
+public class AMQTestConnection_0_10 extends AMQConnection
+{
+    public AMQTestConnection_0_10(String url) throws Exception
+    {
+        super(url);
+    }
+    
+    public Connection getConnection()
+    {
+        return((AMQConnectionDelegate_0_10)_delegate).getQpidConnection();
+    }    
+}