You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2009/02/05 16:06:10 UTC
svn commit: r741123 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp
Author: aconway
Date: Thu Feb 5 15:06:09 2009
New Revision: 741123
URL: http://svn.apache.org/viewvc?rev=741123&view=rev
Log:
QPID-1618 from Mick Goulish: brokers joining cluster store persistent messages that have been sent but not acknowledged.
Modified:
qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp?rev=741123&r1=741122&r2=741123&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp Thu Feb 5 15:06:09 2009
@@ -319,6 +319,11 @@
if (completed) dr.complete();
if (ended) dr.setEnded(); // Exsitance of message
semanticState().record(dr); // Part of the session's unacked list.
+
+ // If the message was unacked, the newbie broker must place
+ // it in its messageStore.
+ if ( m.payload && m.payload->isPersistent() && !completed && !ended && !accepted && !cancelled )
+ queue->enqueue ( 0, m.payload );
}
void Connection::queuePosition(const string& qname, const SequenceNumber& position) {
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org