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 <[email protected]> Authored: Mon Aug 3 22:04:20 2015 +0100 Committer: Gordon Sim <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
