From efa84dfce326ea33e2eddfd3cb8142a8d708e101 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 29 May 2013 18:03:50 +0000 Subject: NO-JIRA: Added connection timeout to python client, used in brokertests. Added an optional timeout parameter to Connection.establish. Set a timeout of 5 seconds in brokertest.py to prevent hanging tests. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1487578 13f79535-47bb-0310-9956-ffa450edef68 --- python/qpid/messaging/endpoints.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'python/qpid') diff --git a/python/qpid/messaging/endpoints.py b/python/qpid/messaging/endpoints.py index 3c9639552c..7621dceb3d 100644 --- a/python/qpid/messaging/endpoints.py +++ b/python/qpid/messaging/endpoints.py @@ -59,13 +59,13 @@ class Connection(Endpoint): """ @static - def establish(url=None, **options): + def establish(url=None, timeout=None, **options): """ Constructs a L{Connection} with the supplied parameters and opens it. """ conn = Connection(url, **options) - conn.open() + conn.open(timeout=timeout) return conn def __init__(self, url=None, **options): @@ -257,14 +257,13 @@ class Connection(Endpoint): self.sessions.pop(ssn.name, 0) @synchronized - def open(self): + def open(self, timeout=None): """ Opens a connection. """ if self._open: raise ConnectionError("already open") self._open = True - timeout = None if self.reconnect and self.reconnect_timeout > 0: timeout = self.reconnect_timeout self.attach(timeout=timeout) -- cgit v1.2.1