diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/LegacyLVQ.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/LegacyLVQ.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/broker/LegacyLVQ.cpp b/qpid/cpp/src/qpid/broker/LegacyLVQ.cpp index 3262e343a3..49c0a32c19 100644 --- a/qpid/cpp/src/qpid/broker/LegacyLVQ.cpp +++ b/qpid/cpp/src/qpid/broker/LegacyLVQ.cpp @@ -32,7 +32,7 @@ void LegacyLVQ::setNoBrowse(bool b) noBrowse = b; } -bool LegacyLVQ::remove(const framing::SequenceNumber& position, QueuedMessage& message) +bool LegacyLVQ::acquire(const framing::SequenceNumber& position, QueuedMessage& message) { Ordering::iterator i = messages.find(position); if (i != messages.end() && i->second.payload == message.payload) { @@ -44,9 +44,9 @@ bool LegacyLVQ::remove(const framing::SequenceNumber& position, QueuedMessage& m } } -bool LegacyLVQ::next(const framing::SequenceNumber& position, QueuedMessage& message) +bool LegacyLVQ::browse(const framing::SequenceNumber& position, QueuedMessage& message, bool unacquired) { - if (MessageMap::next(position, message)) { + if (MessageMap::browse(position, message, unacquired)) { if (!noBrowse) index.erase(getKey(message)); return true; } else { |