Cleanup logging

Troubleshoot blocking connection usage
NeonGeckoCom · Jan 21, 2025 · 643e386 · 643e386
1 parent a4d9083
commit 643e386
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py
@@ -300,8 +300,6 @@ def emit_mq_message(cls,
                                 cls.create_unique_id())
 
         def _on_channel_open(new_channel):
-            while not new_channel.is_open:
-                LOG.warning(f"Waiting for channel to open ({new_channel})")
             if exchange:
                 new_channel.exchange_declare(exchange=exchange,
                                              exchange_type=exchange_type,
@@ -321,10 +319,10 @@ def _on_channel_open(new_channel):
             new_channel.close()
 
         if isinstance(connection, pika.BlockingConnection):
-            LOG.info(f"Using blocking connection for queue: {queue}")
+            LOG.info(f"Using blocking connection for request: {request_data}")
             _on_channel_open(connection.channel())
         else:
-            LOG.info(f"Using select connection for queue: {queue}")
+            LOG.debug(f"Using select connection for queue: {queue}")
             connection.channel(on_open_callback=_on_channel_open)
 
         LOG.debug(f"sent message: {request_data['message_id']}")