diff --git a/core/src/main/scala/com/avast/clients/rabbitmq/DefaultRabbitMQProducer.scala b/core/src/main/scala/com/avast/clients/rabbitmq/DefaultRabbitMQProducer.scala index 21158748..2ac06635 100644 --- a/core/src/main/scala/com/avast/clients/rabbitmq/DefaultRabbitMQProducer.scala +++ b/core/src/main/scala/com/avast/clients/rabbitmq/DefaultRabbitMQProducer.scala @@ -52,6 +52,8 @@ class DefaultRabbitMQProducer[F[_], A: ProductConverter](name: String, private def send(routingKey: String, body: Bytes, properties: MessageProperties): Task[Unit] = { Task { + logger.debug(s"Sending message with ${body.size()} B to exchange $exchangeName with routing key $routingKey and $properties") + try { sendLock.synchronized { // see https://www.rabbitmq.com/api-guide.html#channel-threads