You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2015/01/16 23:37:05 UTC
qpid-proton git commit: Allow link name to be specified by
application when using BlockingConnection
Repository: qpid-proton
Updated Branches:
refs/heads/master c7079a957 -> 6982026d7
Allow link name to be specified by application when using BlockingConnection
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/6982026d
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/6982026d
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/6982026d
Branch: refs/heads/master
Commit: 6982026d7b47684ec8d4a729d3c2dbed80dc31f0
Parents: c7079a9
Author: Gordon Sim <gs...@redhat.com>
Authored: Fri Jan 16 22:37:50 2015 +0000
Committer: Gordon Sim <gs...@redhat.com>
Committed: Fri Jan 16 22:37:50 2015 +0000
----------------------------------------------------------------------
proton-c/bindings/python/proton/utils.py | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/6982026d/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 bd8059a..f4740b5 100644
--- a/proton-c/bindings/python/proton/utils.py
+++ b/proton-c/bindings/python/proton/utils.py
@@ -90,10 +90,10 @@ class BlockingConnection(Handler):
self.wait(lambda: not (self.conn.state & Endpoint.REMOTE_UNINIT),
msg="Opening connection")
- def create_sender(self, address, handler=None):
- return BlockingSender(self, self.container.create_sender(self.conn, address, handler=handler))
+ def create_sender(self, address, handler=None, name=None):
+ return BlockingSender(self, self.container.create_sender(self.conn, address, name=name, handler=handler))
- def create_receiver(self, address, credit=None, dynamic=False, handler=None):
+ def create_receiver(self, address, credit=None, dynamic=False, handler=None, name=None):
prefetch = credit
if handler:
fetcher = None
@@ -102,7 +102,7 @@ class BlockingConnection(Handler):
else:
fetcher = Fetcher(credit)
return BlockingReceiver(
- self, self.container.create_receiver(self.conn, address, dynamic=dynamic, handler=handler or fetcher), fetcher, credit=prefetch)
+ self, self.container.create_receiver(self.conn, address, name=name, dynamic=dynamic, handler=handler or fetcher), fetcher, credit=prefetch)
def close(self):
self.conn.close()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org