Producer logging sending of message

avast · Nov 20, 2018 · 5fe6957 · 5fe6957
1 parent 18d0ac5
commit 5fe6957
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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