diff options
author | Alan Conway <aconway@apache.org> | 2009-05-04 17:22:33 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2009-05-04 17:22:33 +0000 |
commit | cf3a9eb8cf578be00f0556ff5d93bfdf7c12aec8 (patch) | |
tree | 2b67937230ab3aaa1770f85125a77376d616dc05 /cpp/src/qpid/client/SubscriptionImpl.h | |
parent | 2407f9f523b0eeeb8988e30c797fdb46039fc3d3 (diff) | |
download | qpid-python-cf3a9eb8cf578be00f0556ff5d93bfdf7c12aec8.tar.gz |
Applied PIMPL pattern to SubscriptionManager.
Cleaned up some sloppy #includes.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@771366 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/SubscriptionImpl.h')
-rw-r--r-- | cpp/src/qpid/client/SubscriptionImpl.h | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/SubscriptionImpl.h b/cpp/src/qpid/client/SubscriptionImpl.h index e2b970ce05..da77213423 100644 --- a/cpp/src/qpid/client/SubscriptionImpl.h +++ b/cpp/src/qpid/client/SubscriptionImpl.h @@ -23,6 +23,7 @@ */ #include "qpid/client/SubscriptionSettings.h" +#include "qpid/client/SubscriptionManager.h" #include "qpid/client/Session.h" #include "qpid/client/MessageListener.h" #include "qpid/client/Demux.h" @@ -37,11 +38,12 @@ namespace qpid { namespace client { class SubscriptionManager; +class SubscriptionManagerImpl; class SubscriptionImpl : public RefCounted, public MessageListener { public: - QPID_CLIENT_EXTERN SubscriptionImpl(SubscriptionManager&, const std::string& queue, - const SubscriptionSettings&, const std::string& name, MessageListener* =0); + QPID_CLIENT_EXTERN SubscriptionImpl(SubscriptionManager, const std::string& queue, + const SubscriptionSettings&, const std::string& name, MessageListener* =0); /** The name of the subsctription, used as the "destination" for messages from the broker. * Usually the same as the queue name but can be set differently. @@ -84,7 +86,7 @@ class SubscriptionImpl : public RefCounted, public MessageListener { QPID_CLIENT_EXTERN Session getSession() const; /** Get the subscription manager associated with this subscription */ - QPID_CLIENT_EXTERN SubscriptionManager& getSubscriptionManager() const; + QPID_CLIENT_EXTERN SubscriptionManager getSubscriptionManager(); /** Send subscription request and issue appropriate flow control commands. */ QPID_CLIENT_EXTERN void subscribe(); @@ -110,7 +112,7 @@ class SubscriptionImpl : public RefCounted, public MessageListener { private: mutable sys::Mutex lock; - SubscriptionManager& manager; + SubscriptionManagerImpl& manager; std::string name, queue; SubscriptionSettings settings; framing::SequenceSet unacquired, unaccepted; |