diff --git a/azure/eventhub/async_ops/receiver_async.py b/azure/eventhub/async_ops/receiver_async.py index 9a09091..c57db34 100644 --- 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 index 6fc786d..066baf3 100644 --- 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 index 9cd6c6f..8f46db3 100644 --- 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 index d96ea0c..f3559e2 100644 --- 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