diff options
Diffstat (limited to 'cpp/src/qpid/broker/Queue.h')
-rw-r--r-- | cpp/src/qpid/broker/Queue.h | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h index 5146024b6b..17f2d8ba91 100644 --- a/cpp/src/qpid/broker/Queue.h +++ b/cpp/src/qpid/broker/Queue.h @@ -95,7 +95,7 @@ namespace qpid { qpid::sys::Serializer<DispatchFunctor> serializer; DispatchFunctor dispatchCallback; framing::SequenceNumber sequence; - ManagementObjectQueue::shared_ptr mgmtObjectPtr; + ManagementObjectQueue::shared_ptr mgmtObject; void pop(); void push(Message::shared_ptr& msg); @@ -103,7 +103,7 @@ namespace qpid { void setPolicy(std::auto_ptr<QueuePolicy> policy); /** * only called by serilizer - */ + */ void dispatch(); void cancel(Consumer::ptr c, Consumers& set); void serviceAllBrowsers(); @@ -115,16 +115,16 @@ namespace qpid { bool exclude(Message::shared_ptr msg); protected: - /** - * Call back from store - */ - virtual void notifyDurableIOComplete(); + /** + * Call back from store + */ + virtual void notifyDurableIOComplete(); public: typedef boost::shared_ptr<Queue> shared_ptr; typedef std::vector<shared_ptr> vector; - + Queue(const string& name, bool autodelete = false, MessageStore* const store = 0, const ConnectionToken* const owner = 0); @@ -135,8 +135,8 @@ namespace qpid { void destroy(); void bound(const string& exchange, const string& key, const qpid::framing::FieldTable& args); void unbind(ExchangeRegistry& exchanges, Queue::shared_ptr shared_ref); - void setMgmt (ManagementObjectQueue::shared_ptr mgmt) { mgmtObjectPtr = mgmt; } - ManagementObjectQueue::shared_ptr getMgmt (void) { return mgmtObjectPtr; } + void setMgmt (ManagementObjectQueue::shared_ptr mgmt) { mgmtObject = mgmt; } + ManagementObjectQueue::shared_ptr getMgmt (void) { return mgmtObject; } bool acquire(const QueuedMessage& msg); @@ -165,7 +165,7 @@ namespace qpid { * Request dispatch any queued messages providing there are * consumers for them. Only one thread can be dispatching * at any time, so this call schedules the despatch based on - * the serilizer policy. + * the serilizer policy. */ void requestDispatch(Consumer::ptr c = Consumer::ptr()); void flush(DispatchCompletion& callback); |