diff options
| author | Gordon Sim <gsim@apache.org> | 2008-11-29 16:01:54 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2008-11-29 16:01:54 +0000 |
| commit | b1df6182bb6f140ce0f6d6dbc76459e518d02cd3 (patch) | |
| tree | b30ba6ac3778ee826198ceb481548f81338bce94 /cpp/src/qpid/broker/Queue.h | |
| parent | e0b5d705f146de1c9064b11ea6e36f77e38711bd (diff) | |
| download | qpid-python-b1df6182bb6f140ce0f6d6dbc76459e518d02cd3.tar.gz | |
QPID-1280: fixed performance regression for multiple subscribers on shared queue
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@721685 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Queue.h')
| -rw-r--r-- | cpp/src/qpid/broker/Queue.h | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h index 76d9a59c3e..1f619c8812 100644 --- a/cpp/src/qpid/broker/Queue.h +++ b/cpp/src/qpid/broker/Queue.h @@ -27,6 +27,7 @@ #include "PersistableQueue.h" #include "QueuePolicy.h" #include "QueueBindings.h" +#include "QueueListeners.h" #include "RateTracker.h" #include "qpid/framing/FieldTable.h" @@ -64,7 +65,6 @@ namespace qpid { class Queue : public boost::enable_shared_from_this<Queue>, public PersistableQueue, public management::Manageable { - typedef std::list<Consumer::shared_ptr> Listeners; typedef std::deque<QueuedMessage> Messages; typedef std::map<string,boost::intrusive_ptr<Message> > LVQ; @@ -80,7 +80,7 @@ namespace qpid { bool inLastNodeFailure; std::string traceId; std::vector<std::string> traceExclude; - Listeners listeners; + QueueListeners listeners; Messages messages; LVQ lvq; mutable qpid::sys::Mutex consumerLock; @@ -94,7 +94,7 @@ namespace qpid { boost::shared_ptr<Exchange> alternateExchange; framing::SequenceNumber sequence; qmf::org::apache::qpid::broker::Queue* mgmtObject; -RateTracker dequeueTracker; + RateTracker dequeueTracker; void push(boost::intrusive_ptr<Message>& msg); void setPolicy(std::auto_ptr<QueuePolicy> policy); @@ -104,7 +104,6 @@ RateTracker dequeueTracker; bool browseNextMessage(QueuedMessage& msg, Consumer::shared_ptr c); void removeListener(Consumer::shared_ptr); - void addListener(Consumer::shared_ptr); bool isExcluded(boost::intrusive_ptr<Message>& msg); |