qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject svn commit: r741123 - /qpid/trunk/qpid/cpp/src/qpid/cluster/Connection.cpp
Date Thu, 05 Feb 2009 15:06:10 GMT
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


Mime
View raw message