Author: tross
Date: Mon Jan 4 22:25:39 2010
New Revision: 895803
URL: http://svn.apache.org/viewvc?rev=895803&view=rev
Log:
QPID-2318 - qpid-tool does not seem to issue session acknowledgements
Added accept for received messages.
Modified:
qpid/trunk/qpid/python/qpid/management.py
Modified: qpid/trunk/qpid/python/qpid/management.py
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/management.py?rev=895803&r1=895802&r2=895803&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/management.py (original)
+++ qpid/trunk/qpid/python/qpid/management.py Mon Jan 4 22:25:39 2010
@@ -196,11 +196,13 @@
""" Receive messages via the topic queue on this channel. """
if self.enabled:
self.tcb (self, msg)
+ self.ssn.message_accept(RangedSet(msg.id))
def replyCb (self, msg):
""" Receive messages via the reply queue on this channel. """
if self.enabled:
self.rcb (self, msg)
+ self.ssn.message_accept(RangedSet(msg.id))
def exceptionCb (self, data):
if self.ecb != None:
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscr...@qpid.apache.org
