Fixed bug in error handling (Azure#100)

Author: annatisch

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:

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:

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

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