Fixed bug in error handling (#100)

Azure · Mar 3, 2019 · 737c5f9 · 737c5f9
1 parent 9217139
commit 737c5f9
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/azure/eventhub/async_ops/receiver_async.py b/azure/eventhub/async_ops/receiver_async.py
@@ -159,8 +159,8 @@ async def _reconnect_async(self):  # pylint: disable=too-many-statements
             if str(shutdown).startswith("Unable to open authentication session") and self.auto_reconnect:
                 log.info("AsyncReceiver couldn't authenticate. Attempting reconnect.")
                 return False
-            log.info("AsyncReceiver connection error (%r). Shutting down.", e)
-            error = EventHubError(str(shutdown), shutdown)
+            log.info("AsyncReceiver connection error (%r). Shutting down.", shutdown)
+            error = EventHubError(str(shutdown))
             await self.close_async(exception=error)
             raise error
         except Exception as e:

diff --git a/azure/eventhub/async_ops/sender_async.py b/azure/eventhub/async_ops/sender_async.py
@@ -144,8 +144,8 @@ async def _reconnect_async(self):
             if str(shutdown).startswith("Unable to open authentication session") and self.auto_reconnect:
                 log.info("AsyncSender couldn't authenticate. Attempting reconnect.")
                 return False
-            log.info("AsyncSender connection error (%r). Shutting down.", e)
-            error = EventHubError(str(shutdown), shutdown)
+            log.info("AsyncSender connection error (%r). Shutting down.", shutdown)
+            error = EventHubError(str(shutdown))
             await self.close_async(exception=error)
             raise error
         except Exception as e:

diff --git a/azure/eventhub/receiver.py b/azure/eventhub/receiver.py
@@ -154,7 +154,7 @@ def _reconnect(self):  # pylint: disable=too-many-statements
             if str(shutdown).startswith("Unable to open authentication session") and self.auto_reconnect:
                 log.info("Receiver couldn't authenticate. Attempting reconnect.")
                 return False
-            log.info("Receiver connection error (%r). Shutting down.", e)
+            log.info("Receiver connection error (%r). Shutting down.", shutdown)
             error = EventHubError(str(shutdown))
             self.close(exception=error)
             raise error

diff --git a/azure/eventhub/sender.py b/azure/eventhub/sender.py
@@ -137,7 +137,7 @@ def _reconnect(self):
             if str(shutdown).startswith("Unable to open authentication session") and self.auto_reconnect:
                 log.info("Sender couldn't authenticate. Attempting reconnect.")
                 return False
-            log.info("Sender connection error (%r). Shutting down.", e)
+            log.info("Sender connection error (%r). Shutting down.", shutdown)
             error = EventHubError(str(shutdown))
             self.close(exception=error)
             raise error