diff options
| author | Alan Conway <aconway@apache.org> | 2011-11-04 20:27:13 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2011-11-04 20:27:13 +0000 |
| commit | 29e3b04915ef30f7e0f769cc1ee3994d99711fef (patch) | |
| tree | 02e49caec0e4e7699413d36eab177a3d5bbb732d /qpid/cpp/src/qpid/broker/Queue.h | |
| parent | 561fe4dd6234c085dc55bbd430dcab7427d2db29 (diff) | |
| download | qpid-python-29e3b04915ef30f7e0f769cc1ee3994d99711fef.tar.gz | |
QPID-2920: Batch acquire/dequeue messages in cluster.qpid-2920-active
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-2920-active@1197749 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Queue.h')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.h b/qpid/cpp/src/qpid/broker/Queue.h index aae858f804..b57ec46adc 100644 --- a/qpid/cpp/src/qpid/broker/Queue.h +++ b/qpid/cpp/src/qpid/broker/Queue.h @@ -24,6 +24,7 @@ #include "qpid/broker/BrokerImportExport.h" #include "qpid/broker/OwnershipToken.h" #include "qpid/broker/Consumer.h" +#include "qpid/broker/Context.h" #include "qpid/broker/Message.h" #include "qpid/broker/Messages.h" #include "qpid/broker/PersistableQueue.h" @@ -130,7 +131,7 @@ class Queue : public boost::enable_shared_from_this<Queue>, int autoDeleteTimeout; boost::intrusive_ptr<qpid::sys::TimerTask> autoDeleteTask; sys::Activity consuming; // Allow consumer threads to be stopped, used by cluster - boost::intrusive_ptr<RefCounted> clusterContext; // Used by cluster + std::auto_ptr<Context> clusterContext; // Clustering state. void push(boost::intrusive_ptr<Message>& msg, bool isRecovery=false); void setPolicy(std::auto_ptr<QueuePolicy> policy); @@ -401,8 +402,8 @@ class Queue : public boost::enable_shared_from_this<Queue>, bool isConsumingStopped(); /** Context information used in a cluster. */ - boost::intrusive_ptr<RefCounted> getClusterContext() { return clusterContext; } - void setClusterContext(boost::intrusive_ptr<RefCounted> context) { clusterContext = context; } + Context* getClusterContext() { return clusterContext.get(); } + void setClusterContext(std::auto_ptr<Context> context) { clusterContext = context; } }; }} // qpid::broker |