summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/SubscriptionImpl.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-05-04 17:22:33 +0000
committerAlan Conway <aconway@apache.org>2009-05-04 17:22:33 +0000
commitcf3a9eb8cf578be00f0556ff5d93bfdf7c12aec8 (patch)
tree2b67937230ab3aaa1770f85125a77376d616dc05 /cpp/src/qpid/client/SubscriptionImpl.h
parent2407f9f523b0eeeb8988e30c797fdb46039fc3d3 (diff)
downloadqpid-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.h10
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;