From f151d8d646f08e869a7015561639b8397abede74 Mon Sep 17 00:00:00 2001 From: Daniel McKnight Date: Mon, 20 Jan 2025 17:25:54 -0800 Subject: [PATCH] Add more logging --- neon_mq_connector/connector.py | 1 + 1 file changed, 1 insertion(+) diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py index e5aec55..7ab6457 100644 --- a/neon_mq_connector/connector.py +++ b/neon_mq_connector/connector.py @@ -321,6 +321,7 @@ def _on_channel_open(new_channel): new_channel.close() if isinstance(connection, pika.BlockingConnection): + LOG.info("Using blocking connection") _on_channel_open(connection.channel()) else: connection.channel(on_open_callback=_on_channel_open)