diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/FifoDistributor.h')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/FifoDistributor.h | 10 |
1 files changed, 1 insertions, 9 deletions
diff --git a/qpid/cpp/src/qpid/broker/FifoDistributor.h b/qpid/cpp/src/qpid/broker/FifoDistributor.h index 245537ed12..aa5ebe28c5 100644 --- a/qpid/cpp/src/qpid/broker/FifoDistributor.h +++ b/qpid/cpp/src/qpid/broker/FifoDistributor.h @@ -38,15 +38,7 @@ class FifoDistributor : public MessageDistributor public: FifoDistributor(Messages& container); - /** Locking Note: all methods assume the caller is holding the Queue::messageLock - * during the method call. - */ - - /** MessageDistributor interface */ - - bool nextConsumableMessage( Consumer::shared_ptr& consumer, QueuedMessage& next ); - bool allocate(const std::string& consumer, const QueuedMessage& target); - bool nextBrowsableMessage( Consumer::shared_ptr& consumer, QueuedMessage& next ); + bool acquire(const std::string& consumer, Message& target); void query(qpid::types::Variant::Map&) const; private: |