summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/exception_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/tests/exception_test.cpp')
-rw-r--r--qpid/cpp/src/tests/exception_test.cpp5
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/cpp/src/tests/exception_test.cpp b/qpid/cpp/src/tests/exception_test.cpp
index 41061173a7..a73ea9e36b 100644
--- a/qpid/cpp/src/tests/exception_test.cpp
+++ b/qpid/cpp/src/tests/exception_test.cpp
@@ -39,6 +39,7 @@ using namespace sys;
using namespace client;
using namespace framing;
+using qpid::broker::Broker;
using boost::bind;
using boost::function;
@@ -88,7 +89,7 @@ QPID_AUTO_TEST_CASE(TestSessionBusy) {
QPID_AUTO_TEST_CASE(DisconnectedPop) {
ProxySessionFixture fix;
- ProxyConnection c(fix.broker->getPort());
+ ProxyConnection c(fix.broker->getPort(Broker::TCP_TRANSPORT));
fix.session.queueDeclare(arg::queue="q");
fix.subs.subscribe(fix.lq, "q");
Catcher<ConnectionException> pop(bind(&LocalQueue::pop, boost::ref(fix.lq)));
@@ -101,7 +102,7 @@ QPID_AUTO_TEST_CASE(DisconnectedListen) {
struct NullListener : public MessageListener {
void received(Message&) { BOOST_FAIL("Unexpected message"); }
} l;
- ProxyConnection c(fix.broker->getPort());
+ ProxyConnection c(fix.broker->getPort(Broker::TCP_TRANSPORT));
fix.session.queueDeclare(arg::queue="q");
fix.subs.subscribe(l, "q");