Skip to content

Commit

Permalink
Add more logging
Browse files Browse the repository at this point in the history
  • Loading branch information
NeonDaniel committed Jan 21, 2025
1 parent 1cbfb85 commit f151d8d
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions neon_mq_connector/connector.py
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down

0 comments on commit f151d8d

Please sign in to comment.