summaryrefslogtreecommitdiff
path: root/cpp/src/tests/BrokerFixture.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-10-20 15:29:46 +0000
committerGordon Sim <gsim@apache.org>2008-10-20 15:29:46 +0000
commit6fcb7dcbd22956828de8aa52a58e66b9df5e7529 (patch)
tree9bdd91484def60b6872fa27c3122cc8477427e04 /cpp/src/tests/BrokerFixture.h
parent7aae076e7c8289ea60a69fd54ea93deb4b7fcdfa (diff)
downloadqpid-python-6fcb7dcbd22956828de8aa52a58e66b9df5e7529.tar.gz
Add option to require that only encrypted connections be accepted.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@706321 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/BrokerFixture.h')
-rw-r--r--cpp/src/tests/BrokerFixture.h8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/tests/BrokerFixture.h b/cpp/src/tests/BrokerFixture.h
index 4e10f82809..b3e68fdc41 100644
--- a/cpp/src/tests/BrokerFixture.h
+++ b/cpp/src/tests/BrokerFixture.h
@@ -52,7 +52,7 @@ struct BrokerFixture : private boost::noncopyable {
// TODO aconway 2007-12-05: At one point BrokerFixture
// tests could hang in Connection ctor if the following
// line is removed. This may not be an issue anymore.
- broker->getPort();
+ broker->getPort(qpid::broker::Broker::TCP_TRANSPORT);
brokerThread = qpid::sys::Thread(*broker);
};
@@ -63,10 +63,10 @@ struct BrokerFixture : private boost::noncopyable {
/** Open a connection to the broker. */
void open(qpid::client::Connection& c) {
- c.open("localhost", broker->getPort());
+ c.open("localhost", broker->getPort(qpid::broker::Broker::TCP_TRANSPORT));
}
- uint16_t getPort() { return broker->getPort(); }
+ uint16_t getPort() { return broker->getPort(qpid::broker::Broker::TCP_TRANSPORT); }
};
/** Connection that opens in its constructor */
@@ -108,7 +108,7 @@ struct SessionFixtureT : BrokerFixture, ClientT<ConnectionType,SessionType> {
SessionFixtureT(Broker::Options opts=Broker::Options()) :
BrokerFixture(opts),
- ClientT<ConnectionType,SessionType>(broker->getPort())
+ ClientT<ConnectionType,SessionType>(broker->getPort(qpid::broker::Broker::TCP_TRANSPORT))
{}
};