From ef958e7b221d38ec76c392f76a66978211d6d1f9 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 9 Apr 2010 15:08:47 +0000 Subject: QPID-664: changed connect() back to open(),removed detach(),defined new exception hierarchy, added ability to re-use reconnect/replay logic for resource-limit-exceeded errors git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@932451 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/messaging/Connection.cpp | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) (limited to 'cpp/src/qpid/messaging/Connection.cpp') diff --git a/cpp/src/qpid/messaging/Connection.cpp b/cpp/src/qpid/messaging/Connection.cpp index 81a72bb876..14e713d425 100644 --- a/cpp/src/qpid/messaging/Connection.cpp +++ b/cpp/src/qpid/messaging/Connection.cpp @@ -39,7 +39,7 @@ Connection::Connection(const Connection& c) : Handle() { PI::cop Connection& Connection::operator=(const Connection& c) { return PI::assign(*this, c); } Connection::~Connection() { PI::dtor(*this); } -Connection::Connection(const std::string& url, const std::string& o) +Connection::Connection(const std::string& url, const std::string& o) throw(InvalidOptionString) { Variant::Map options; AddressParser parser(o); @@ -54,9 +54,8 @@ Connection::Connection(const std::string& url, const Variant::Map& options) PI::ctor(*this, new qpid::client::amqp0_10::ConnectionImpl(url, options)); } -void Connection::connect() { impl->connect(); } -bool Connection::isConnected() { return impl->isConnected(); } -void Connection::detach() { impl->detach(); } +void Connection::open() { impl->open(); } +bool Connection::isOpen() { return impl->isOpen(); } void Connection::close() { impl->close(); } Session Connection::createSession(const std::string& name) { return impl->newSession(false, name); } Session Connection::createTransactionalSession(const std::string& name) @@ -69,6 +68,4 @@ void Connection::setOption(const std::string& name, const Variant& value) impl->setOption(name, value); } -InvalidOptionString::InvalidOptionString(const std::string& msg) : Exception(msg) {} - }} // namespace qpid::messaging -- cgit v1.2.1