diff options
| -rw-r--r-- | qpid/extras/qmf/src/py/qmf/console.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/qpid/extras/qmf/src/py/qmf/console.py b/qpid/extras/qmf/src/py/qmf/console.py index 9967ba2b78..ea9b8f6a76 100644 --- a/qpid/extras/qmf/src/py/qmf/console.py +++ b/qpid/extras/qmf/src/py/qmf/console.py @@ -2227,7 +2227,7 @@ class Broker(Thread): self.amqpSession.message_subscribe(queue=self.topicName, destination="tdest", accept_mode=self.amqpSession.accept_mode.none, acquire_mode=self.amqpSession.acquire_mode.pre_acquired) - self.amqpSession.incoming("tdest").listen(self._v1Cb) + self.amqpSession.incoming("tdest").listen(self._v1Cb, self._exceptionCb) self.amqpSession.message_set_flow_mode(destination="tdest", flow_mode=self.amqpSession.flow_mode.window) self.amqpSession.message_flow(destination="tdest", unit=self.amqpSession.credit_unit.byte, value=0xFFFFFFFFL) self.amqpSession.message_flow(destination="tdest", unit=self.amqpSession.credit_unit.message, value=200) |