diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-08-10 22:40:03 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-08-10 22:40:03 +0000 |
| commit | 7d718b3b5f6fed1747ef419fa9d4874a4fa707a9 (patch) | |
| tree | e22005159cb6f90b841303845f062e514a4761a0 | |
| parent | 8f3227a4b6fcb0d07d9410972fed9e564bbe685d (diff) | |
| download | qpid-python-7d718b3b5f6fed1747ef419fa9d4874a4fa707a9.tar.gz | |
QMF: include exception handler callback in v1 topic listener
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@984253 13f79535-47bb-0310-9956-ffa450edef68
| -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) |