Repository: qpid-proton Updated Branches: refs/heads/master 02d82cdfc -> cdee05455
PROTON-817: pass through options when creating blocking links (patch from Ted Ross) Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/54795323 Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/54795323 Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/54795323 Branch: refs/heads/master Commit: 54795323e2524e650cb7b0de371fd9a7692610d4 Parents: 02d82cd Author: Gordon Sim <[email protected]> Authored: Fri Feb 6 09:38:03 2015 +0000 Committer: Gordon Sim <[email protected]> Committed: Fri Feb 6 09:38:03 2015 +0000 ---------------------------------------------------------------------- proton-c/bindings/python/proton/utils.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/54795323/proton-c/bindings/python/proton/utils.py ---------------------------------------------------------------------- diff --git a/proton-c/bindings/python/proton/utils.py b/proton-c/bindings/python/proton/utils.py index 2b3af6e..d0c9f2b 100644 --- a/proton-c/bindings/python/proton/utils.py +++ b/proton-c/bindings/python/proton/utils.py @@ -181,7 +181,7 @@ class BlockingConnection(Handler): msg="Opening connection") def create_sender(self, address, handler=None, name=None, options=None): - return BlockingSender(self, self.container.create_sender(self.conn, utf8(address), name=utf8(name), handler=handler)) + return BlockingSender(self, self.container.create_sender(self.conn, utf8(address), name=utf8(name), handler=handler, options=options)) def create_receiver(self, address, credit=None, dynamic=False, handler=None, name=None, options=None): prefetch = credit @@ -192,7 +192,7 @@ class BlockingConnection(Handler): else: fetcher = Fetcher(credit) return BlockingReceiver( - self, self.container.create_receiver(self.conn, utf8(address), name=utf8(name), dynamic=dynamic, handler=handler or fetcher), fetcher, credit=prefetch) + self, self.container.create_receiver(self.conn, utf8(address), name=utf8(name), dynamic=dynamic, handler=handler or fetcher, options=options), fetcher, credit=prefetch) def close(self): self.conn.close() --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
