Repository: qpid-proton Updated Branches: refs/heads/master ca88f3416 -> fb439633e
PROTON-1530: delegate unhandled events Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/fb439633 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/fb439633 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/fb439633 Branch: refs/heads/master Commit: fb439633ea999ecd2f0967bc94c03c276a2820c4 Parents: ca88f34 Author: Gordon Sim <g...@redhat.com> Authored: Fri Aug 4 18:10:45 2017 +0100 Committer: Gordon Sim <g...@redhat.com> Committed: Fri Aug 4 18:10:45 2017 +0100 ---------------------------------------------------------------------- proton-c/bindings/python/proton/reactor.py | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/fb439633/proton-c/bindings/python/proton/reactor.py ---------------------------------------------------------------------- diff --git a/proton-c/bindings/python/proton/reactor.py b/proton-c/bindings/python/proton/reactor.py index 5f6d8cb..4beede0 100644 --- a/proton-c/bindings/python/proton/reactor.py +++ b/proton-c/bindings/python/proton/reactor.py @@ -864,6 +864,11 @@ class Container(Reactor): if hasattr(event.delivery, "transaction"): event.transaction = event.delivery.transaction event.delivery.transaction.handle_outcome(event) + + def on_unhandled(self, method, event): + if handler: + event.dispatch(handler) + context._txn_ctrl = self.create_sender(context, None, name='txn-ctrl', handler=InternalTransactionHandler()) context._txn_ctrl.target.type = Terminus.COORDINATOR context._txn_ctrl.target.capabilities.put_object(symbol(u'amqp:local-transactions')) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
