Author: aconway
Date: Thu Jan 19 23:06:07 2012
New Revision: 1233663
URL: http://svn.apache.org/viewvc?rev=1233663&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-2/qpid/cpp/src/qpid/broker/MessageDeque.cpp
Modified: qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/MessageDeque.cpp
URL:
http://svn.apache.org/viewvc/qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/MessageDeque.cpp?rev=1233663&r1=1233662&r2=1233663&view=diff
==============================================================================
--- qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/MessageDeque.cpp
(original)
+++ qpid/branches/qpid-3603-2/qpid/cpp/src/qpid/broker/MessageDeque.cpp Thu Jan
19 23:06:07 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:[email protected]
