diff options
| author | Alan Conway <aconway@apache.org> | 2009-10-26 20:11:08 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-10-26 20:11:08 +0000 |
| commit | b6eb88609aea82e676f33ae8ff68918b68b81d33 (patch) | |
| tree | 7180c10a249f84f635459086ffab7fe93ece3e01 /cpp/src/qpid/client/amqp0_10/ConnectionImpl.h | |
| parent | f5c7bf95dd04dc1cf0248511982a18a45847da14 (diff) | |
| download | qpid-python-b6eb88609aea82e676f33ae8ff68918b68b81d33.tar.gz | |
Separate FailoverListener from client::Connection.
client::ConnectionImpl used to contain a FailoverListener to subscribe
for updates on the amq.failover exchange. This caused some lifecycle
issues including memory leaks.
Now FailoverListener is a public API class that the user must create
associated with a session to get known-broker updates.
Removed the weak_ptr logic in client::SessionImpl which was only
required because of FailoverListener.
Made SessionImpl::close() idempotent. Gets rid of spurious warning
messages in some tests.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@829931 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/amqp0_10/ConnectionImpl.h')
| -rw-r--r-- | cpp/src/qpid/client/amqp0_10/ConnectionImpl.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h index 565f2ec7ec..f4bc09594d 100644 --- a/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h +++ b/cpp/src/qpid/client/amqp0_10/ConnectionImpl.h @@ -25,6 +25,7 @@ #include "qpid/messaging/Variant.h" #include "qpid/Url.h" #include "qpid/client/Connection.h" +#include "qpid/client/FailoverListener.h" #include "qpid/client/ConnectionSettings.h" #include "qpid/sys/Mutex.h" #include "qpid/sys/Semaphore.h" @@ -50,6 +51,7 @@ class ConnectionImpl : public qpid::messaging::ConnectionImpl qpid::sys::Mutex lock;//used to protect data structures qpid::sys::Semaphore semaphore;//used to coordinate reconnection qpid::client::Connection connection; + std::auto_ptr<FailoverListener> failoverListener; qpid::Url url; qpid::client::ConnectionSettings settings; Sessions sessions; |