You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2009/10/23 19:44:35 UTC
svn commit: r829142 - /qpid/trunk/qpid/python/qpid/driver.py
Author: rhs
Date: Fri Oct 23 17:44:34 2009
New Revision: 829142
URL: http://svn.apache.org/viewvc?rev=829142&view=rev
Log:
update the broker state so we avoid accidentally generating overlapping drains
Modified:
qpid/trunk/qpid/python/qpid/driver.py
Modified: qpid/trunk/qpid/python/qpid/driver.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/driver.py?rev=829142&r1=829141&r2=829142&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/driver.py (original)
+++ qpid/trunk/qpid/python/qpid/driver.py Fri Oct 23 17:44:34 2009
@@ -702,6 +702,7 @@
sst.write_cmd(MessageStop(rcv.destination, sync=True), do_stop)
if rcv.draining:
+ _rcv.draining = True
def do_flush():
rcv.impending = rcv.received
rcv.granted = rcv.impending
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org