Repository: qpid-proton
Updated Branches:
  refs/heads/master 4d25d88f5 -> 9eaca615c


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/master
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-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org

Reply via email to