Log async consumer param with other registration logs

NeonGeckoCom · Jan 15, 2025 · e7d56b1 · e7d56b1
1 parent 4ab9b2c
commit e7d56b1
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/neon_mq_connector/connector.py b/neon_mq_connector/connector.py
@@ -460,10 +460,12 @@ def register_consumer(self, name: str, vhost: str, queue: str,
 
         if exchange_type == ExchangeType.fanout.value:
             LOG.info(f'Subscriber exchange listener registered: '
-                     f'[name={name},exchange={exchange},vhost={vhost}]')
+                     f'[name={name},exchange={exchange},vhost={vhost},'
+                     f'async={self.async_consumers_enabled}]')
         else:
             LOG.info(f'Consumer queue listener registered: '
-                     f'[name={name},queue={queue},vhost={vhost}]')
+                     f'[name={name},queue={queue},vhost={vhost},'
+                     f'async={self.async_consumers_enabled}]')
 
         self.consumers[name] = self.consumer_thread_cls(**self.consumer_properties[name]['properties'])