Author: aconway
Date: Fri Feb 17 14:06:58 2012
New Revision: 1245493
URL: http://svn.apache.org/viewvc?rev=1245493&view=rev
Log:
QPID-3603: Fix bug in MessageDeque::acquire.
Acquire was returning incorrect results if the acquired position was
before the first availble index.
Modified:
qpid/branches/qpid-3603-7/qpid/cpp/src/qpid/broker/MessageDeque.cpp
Modified: qpid/branches/qpid-3603-7/qpid/cpp/src/qpid/broker/MessageDeque.cpp
URL:
http://svn.apache.org/viewvc/qpid/branches/qpid-3603-7/qpid/cpp/src/qpid/broker/MessageDeque.cpp?rev=1245493&r1=1245492&r2=1245493&view=diff
==============================================================================
--- qpid/branches/qpid-3603-7/qpid/cpp/src/qpid/broker/MessageDeque.cpp
(original)
+++ qpid/branches/qpid-3603-7/qpid/cpp/src/qpid/broker/MessageDeque.cpp Fri Feb
17 14:06:58 2012
@@ -70,6 +70,7 @@ void MessageDeque::release(const QueuedM
bool MessageDeque::acquire(const framing::SequenceNumber& position,
QueuedMessage& message)
{
+ if (position < messages.front().position) return false;
size_t i = index(position);
if (i < messages.size()) {
QueuedMessage& temp = messages[i];
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
