You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2017/09/01 15:03:38 UTC
[10/50] qpid-proton git commit: PROTON-1530: delegate unhandled events
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/go1
Commit: fb439633ea999ecd2f0967bc94c03c276a2820c4
Parents: ca88f34
Author: Gordon Sim <gs...@redhat.com>
Authored: Fri Aug 4 18:10:45 2017 +0100
Committer: Gordon Sim <gs...@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-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org