diff options
| author | Gordon Sim <gsim@apache.org> | 2011-02-10 10:12:41 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2011-02-10 10:12:41 +0000 |
| commit | 731d6c4b13ed7ae5941a4b0f969be357f3d7e831 (patch) | |
| tree | 5fc47c2ce19bbc0872356ef9c5f5ef073752f2cb /cpp/src/qpid/broker/Message.h | |
| parent | 8ead4c97b75e508a877e8d446a5bef096e606d84 (diff) | |
| download | qpid-python-731d6c4b13ed7ae5941a4b0f969be357f3d7e831.tar.gz | |
QPID-529: Priority queue implementation
QPID-2104: LVQ enhancement
These both required some refactoring of the Queue class to allow cleaner implementation of different types of behaviour. The in-memory storage of messages is now abstracted out behind an interface specified by qpid::broker::Messages which qpid::broker::Queue uses. Different implementations of that are available for the standard FIFO queue, priority queues and LVQ (I have also separated out the 'legacy' implementation of LVQ from the new version driven by QPID-2104).
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1069322 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Message.h')
| -rw-r--r-- | cpp/src/qpid/broker/Message.h | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/cpp/src/qpid/broker/Message.h b/cpp/src/qpid/broker/Message.h index ee80657f39..f7dd2734b6 100644 --- a/cpp/src/qpid/broker/Message.h +++ b/cpp/src/qpid/broker/Message.h @@ -153,8 +153,6 @@ public: void forcePersistent(); bool isForcedPersistent(); - boost::intrusive_ptr<Message>& getReplacementMessage(const Queue* qfor) const; - void setReplacementMessage(boost::intrusive_ptr<Message> msg, const Queue* qfor); /** Call cb when enqueue is complete, may call immediately. Holds cb by reference. */ void setEnqueueCompleteCallback(MessageCallback& cb); @@ -167,8 +165,6 @@ public: uint8_t getPriority() const; private: - typedef std::map<const Queue*,boost::intrusive_ptr<Message> > Replacement; - MessageAdapter& getAdapter() const; void allEnqueuesComplete(); void allDequeuesComplete(); @@ -188,7 +184,6 @@ public: static TransferAdapter TRANSFER; - mutable Replacement replacement; mutable boost::intrusive_ptr<Message> empty; sys::Monitor callbackLock; |