diff options
Diffstat (limited to 'python')
| -rw-r--r-- | python/qpid/management.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/python/qpid/management.py b/python/qpid/management.py index 325ab4903d..5ba936aa0b 100644 --- a/python/qpid/management.py +++ b/python/qpid/management.py @@ -196,11 +196,13 @@ class managementChannel: """ 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: |