qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject [1/2] qpid-proton git commit: PROTON-972: allow heartbeat to be specified for BlockingConnection
Date Tue, 04 Aug 2015 16:52:02 GMT
Repository: qpid-proton
Updated Branches:
  refs/heads/0.10.x 54d4c098d -> 8e3231d0b


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/8fca85a2
Tree: http://git-wip-us.apache.org/repos/asf/qpid-proton/tree/8fca85a2
Diff: http://git-wip-us.apache.org/repos/asf/qpid-proton/diff/8fca85a2

Branch: refs/heads/0.10.x
Commit: 8fca85a27bd796fc896d79ba7e1bf0ed84b0df6b
Parents: 54d4c09
Author: Gordon Sim <gsim@redhat.com>
Authored: Mon Aug 3 22:04:20 2015 +0100
Committer: Gordon Sim <gsim@redhat.com>
Committed: Tue Aug 4 17:43:56 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/8fca85a2/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