Attachment 706773 Details for Bug 908224 – Uses reconnect and reconnect_timeout if supplied

[patch] Uses reconnect and reconnect_timeout if supplied

endpoints-bz908224.patch (text/plain), 1.10 KB, created by Ernie on 2013-03-07 19:29:04 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Ernie

Created: 2013-03-07 19:29:04 UTC

Size: 1.10 KB

patch

obsolete

>Index: python/qpid/messaging/endpoints.py
>===================================================================
>--- python/qpid/messaging/endpoints.py	(revision 1448793)
>+++ python/qpid/messaging/endpoints.py	(working copy)
>@@ -253,7 +253,11 @@
>     if self._open:
>       raise ConnectionError("already open")
>     self._open = True
>-    self.attach()
>+    timeout = None
>+    if self.reconnect:
>+        if self.reconnect_timeout and self.reconnect_timeout > 0:
>+            timeout = self.reconnect_timeout
>+    self.attach(timeout=timeout)
> 
>   @synchronized
>   def opened(self):
>@@ -263,7 +267,7 @@
>     return self._open
> 
>   @synchronized
>-  def attach(self):
>+  def attach(self, timeout=None):
>     """
>     Attach to the remote endpoint.
>     """
>@@ -271,7 +275,8 @@
>       self._connected = True
>       self._driver.start()
>       self._wakeup()
>-    self._ewait(lambda: self._transport_connected and not self._unlinked())
>+    if not self._ewait(lambda: self._transport_connected and not self._unlinked(), timeout=timeout):
>+        raise Timeout("Connection attach timed out")
> 
>   def _unlinked(self):
>     return [l

Actions: View | Diff

Attachments on bug 908224: 706773 | 739604