1 files changed, 8 insertions, 0 deletions
diff --git a/cpp/src/tests/MessagingFixture.h b/cpp/src/tests/MessagingFixture.h
index c8ae86dbc3..18cdeb1701 100644
--- a/cpp/src/tests/MessagingFixture.h
+++ b/cpp/src/tests/MessagingFixture.h
@@ -113,6 +113,14 @@ struct MessagingFixture : public BrokerFixture
         return connection;
     }
 
+    /** Open a connection to the broker. */
+    qpid::messaging::Connection newConnection()
+    {
+        qpid::messaging::Connection connection(
+            (boost::format("amqp:tcp:localhost:%1%") % (broker->getPort(qpid::broker::Broker::TCP_TRANSPORT))).str());
+        return connection;
+    }
+
     void ping(const qpid::messaging::Address& address)
     {
         messaging::Receiver r = session.createReceiver(address);