Repository: qpid-proton Updated Branches: refs/heads/master d1123b0e9 -> 6136f1125
add ability to push messages to the reactor Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/c500b814 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/c500b814 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/c500b814 Branch: refs/heads/master Commit: c500b814778a91f6075d1e09da5b87d9dfd0448e Parents: 277c0b4 Author: Gordon Sim <[email protected]> Authored: Wed Feb 11 22:20:33 2015 +0000 Committer: Gordon Sim <[email protected]> Committed: Thu Feb 12 13:48:51 2015 +0000 ---------------------------------------------------------------------- proton-c/bindings/python/proton/reactors.py | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/c500b814/proton-c/bindings/python/proton/reactors.py ---------------------------------------------------------------------- diff --git a/proton-c/bindings/python/proton/reactors.py b/proton-c/bindings/python/proton/reactors.py index 5ef2aed..dd29892 100644 --- a/proton-c/bindings/python/proton/reactors.py +++ b/proton-c/bindings/python/proton/reactors.py @@ -1019,6 +1019,9 @@ class Reactor(Wrapper): def update(self, sel): pn_reactor_update(self._impl, sel._impl) + def push_event(self, obj, etype): + pn_collector_put(pn_reactor_collector(self._impl), PN_PYREF, pn_py2void(obj), etype.number) + from proton import wrappers as _wrappers _wrappers["pn_reactor"] = lambda x: Reactor.wrap(pn_cast_pn_reactor(x)) _wrappers["pn_task"] = lambda x: Task.wrap(pn_cast_pn_task(x)) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
