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@1487578 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 3 insertions, 4 deletions

diff --git a/qpid/python/qpid/messaging/endpoints.py b/qpid/python/qpid/messaging/endpoints.py
index 3c9639552c..7621dceb3d 100644
--- a/qpid/python/qpid/messaging/endpoints.py
+++ b/qpid/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)