diff options
Diffstat (limited to 'cpp/src/tests/BrokerFixture.h')
-rw-r--r-- | cpp/src/tests/BrokerFixture.h | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/tests/BrokerFixture.h b/cpp/src/tests/BrokerFixture.h index 566fbda406..29920bb71a 100644 --- a/cpp/src/tests/BrokerFixture.h +++ b/cpp/src/tests/BrokerFixture.h @@ -122,10 +122,10 @@ struct ClientT { qpid::client::LocalQueue lq; std::string name; - ClientT(uint16_t port, const std::string& name_=std::string()) - : connection(port), session(connection.newSession(name_)), subs(session), name(name_) {} - ClientT(const qpid::client::ConnectionSettings& settings, const std::string& name_=std::string()) - : connection(settings), session(connection.newSession(name_)), subs(session), name(name_) {} + ClientT(uint16_t port, const std::string& name_=std::string(), int timeout=0) + : connection(port), session(connection.newSession(name_,timeout)), subs(session), name(name_) {} + ClientT(const qpid::client::ConnectionSettings& settings, const std::string& name_=std::string(), int timeout=0) + : connection(settings), session(connection.newSession(name_, timeout)), subs(session), name(name_) {} ~ClientT() { close(); } void close() { session.close(); connection.close(); } |