qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject qpid-proton git commit: PROTON-972: allow heartbeat to be specified for BlockingConnection
Date Mon, 03 Aug 2015 21:02:58 GMT
Repository: qpid-proton
Updated Branches:
  refs/heads/master b7a1fe9ac -> 9d1604984


PROTON-972: allow heartbeat to be specified for 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/9d160498
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/9d160498
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/9d160498

Branch: refs/heads/master
Commit: 9d160498460e53d1c5af720c3bf7fb8ea3f91701
Parents: b7a1fe9
Author: Gordon Sim <gsim@redhat.com>
Authored: Mon Aug 3 22:04:20 2015 +0100
Committer: Gordon Sim <gsim@redhat.com>
Committed: Mon Aug 3 22:04:20 2015 +0100

----------------------------------------------------------------------
 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/9d160498/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 880c466..062df5d 100644
--- a/proton-c/bindings/python/proton/utils.py
+++ b/proton-c/bindings/python/proton/utils.py
@@ -185,13 +185,13 @@ class BlockingConnection(Handler):
     """
     A synchronous style connection wrapper.
     """
-    def __init__(self, url, timeout=None, container=None, ssl_domain=None):
+    def __init__(self, url, timeout=None, container=None, ssl_domain=None, heartbeat=None):
         self.timeout = timeout
         self.container = container or Container()
         self.container.timeout = self.timeout
         self.container.start()
         self.url = Url(url).defaults()
-        self.conn = self.container.connect(url=self.url, handler=self, ssl_domain=ssl_domain,
reconnect=False)
+        self.conn = self.container.connect(url=self.url, handler=self, ssl_domain=ssl_domain,
reconnect=False, heartbeat=heartbeat)
         self.wait(lambda: not (self.conn.state & Endpoint.REMOTE_UNINIT),
                   msg="Opening connection")
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message