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:42 UTC
[14/50] qpid-proton git commit: PROTON-1506: Expose max frame size in
the python binding; thanks to Gordon Sim for the patch
PROTON-1506: Expose max frame size in the python binding; thanks to Gordon Sim for the patch
Project: http://git-wip-us.apache.org/repos/asf/qpid-proton/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-proton/commit/9eaca615
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/9eaca615
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/9eaca615
Branch: refs/heads/go1
Commit: 9eaca615c5f5aa97d89d1b87471d81bff7237df0
Parents: 4d25d88
Author: Justin Ross <jr...@apache.org>
Authored: Thu Aug 10 05:27:43 2017 -0700
Committer: Justin Ross <jr...@apache.org>
Committed: Thu Aug 10 05:27:43 2017 -0700
----------------------------------------------------------------------
proton-c/bindings/python/proton/reactor.py | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-proton/blob/9eaca615/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 4beede0..7b7c701 100644
--- a/proton-c/bindings/python/proton/reactor.py
+++ b/proton-c/bindings/python/proton/reactor.py
@@ -543,6 +543,7 @@ class Connector(Handler):
self.password = None
self.virtual_host = None
self.ssl_sni = None
+ self.max_frame_size = None
def _connect(self, connection, reactor):
assert(reactor is not None)
@@ -575,6 +576,8 @@ class Connector(Handler):
raise SSLUnavailable("amqps: SSL libraries not found")
self.ssl = SSL(transport, self.ssl_domain)
self.ssl.peer_hostname = self.ssl_sni or self.virtual_host or url.host
+ if self.max_frame_size:
+ transport.max_frame_size = self.max_frame_size
def on_connection_local_open(self, event):
self._connect(event.connection, event.reactor)
@@ -735,6 +738,7 @@ class Container(Reactor):
# only set hostname if virtual-host is a non-empty string
conn.hostname = connector.virtual_host
connector.ssl_sni = kwargs.get('sni')
+ connector.max_frame_size = kwargs.get('max_frame_size')
conn._overrides = connector
if url: connector.address = Urls([url])
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org