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 | 5b2d619491d19dbefaa9b1190eaa5d88215bf539 (patch) | |
| tree | f4c9e485839eefb7e5ce83494731a35d21ed5aa3 | |
| parent | b36ac0893068ca4bb0d84ff2280b43f7ac2e1edd (diff) | |
| download | qpid-python-5b2d619491d19dbefaa9b1190eaa5d88215bf539.tar.gz | |
QMF: include exception handler callback in v1 topic listener
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@984253 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | extras/qmf/src/py/qmf/console.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/extras/qmf/src/py/qmf/console.py b/extras/qmf/src/py/qmf/console.py index 9967ba2b78..ea9b8f6a76 100644 --- a/extras/qmf/src/py/qmf/console.py +++ b/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) |