improve error reporting

sanderegg · sanderegg · commit 817588be4019 · 2025-09-18T15:05:07.000+02:00
diff --git a/packages/service-library/src/servicelib/rabbitmq/_client.py b/packages/service-library/src/servicelib/rabbitmq/_client.py
@@ -118,6 +118,8 @@ async def _on_message(
                         message_handler, max_retries_upon_error, message
                     )
     except ChannelInvalidStateError as exc:
+        # NOTE: this error can happen as can be seen in aio-pika code
+        # see https://github.com/mosquito/aio-pika/blob/master/aio_pika/robust_queue.py
         _logger.exception(
             **create_troubleshooting_log_kwargs(
                 "Cannot process message because channel is closed. Message will be requeued by RabbitMQ",

Original file line number	Diff line number	Diff line change
`@@ -118,6 +118,8 @@ async def _on_message(`
`118`	`118`	`message_handler, max_retries_upon_error, message`
`119`	`119`	`)`
`120`	`120`	`except ChannelInvalidStateError as exc:`
	`121`	`+ # NOTE: this error can happen as can be seen in aio-pika code`
	`122`	`+ # see https://github.com/mosquito/aio-pika/blob/master/aio_pika/robust_queue.py`
`121`	`123`	`_logger.exception(`
`122`	`124`	`**create_troubleshooting_log_kwargs(`
`123`	`125`	`"Cannot process message because channel is closed. Message will be requeued by RabbitMQ",`