From 2c02800dc10df5565651586834ff047acaaad50c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Michal=20Charv=C3=A1t?= Date: Tue, 1 Aug 2023 11:02:03 +0200 Subject: [PATCH] chore: core - publisher confirmations - change log level of the message in the case of unexpected delivery tag --- .../publisher/PublishConfirmsRabbitMQProducer.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/main/scala/com/avast/clients/rabbitmq/publisher/PublishConfirmsRabbitMQProducer.scala b/core/src/main/scala/com/avast/clients/rabbitmq/publisher/PublishConfirmsRabbitMQProducer.scala index 978d4183..f97106a0 100644 --- a/core/src/main/scala/com/avast/clients/rabbitmq/publisher/PublishConfirmsRabbitMQProducer.scala +++ b/core/src/main/scala/com/avast/clients/rabbitmq/publisher/PublishConfirmsRabbitMQProducer.scala @@ -7,12 +7,12 @@ import cats.implicits._ import com.avast.bytes.Bytes import com.avast.clients.rabbitmq.api.{MaxAttemptsReached, MessageProperties, NotAcknowledgedPublish} import com.avast.clients.rabbitmq.logging.ImplicitContextLogger -import com.avast.clients.rabbitmq.{startAndForget, CorrelationId, ProductConverter, ServerChannel} +import com.avast.clients.rabbitmq.{CorrelationId, ProductConverter, ServerChannel, startAndForget} import com.avast.metrics.scalaeffectapi.Monitor import com.rabbitmq.client.ConfirmListener import java.util.concurrent.ConcurrentHashMap -import scala.collection.JavaConverters._ +import scala.jdk.CollectionConverters._ class PublishConfirmsRabbitMQProducer[F[_], A: ProductConverter](name: String, exchangeName: String, channel: ServerChannel, @@ -108,7 +108,7 @@ class PublishConfirmsRabbitMQProducer[F[_], A: ProductConverter](name: String, confirmationCallbacks.get(deliveryTag) match { case Some(callback) => callback.complete(result) case None => - logger.plainError(s"Received confirmation for unknown delivery tag $deliveryTag with result $result. That is unexpected state.") + logger.plainDebug(s"Received confirmation for unknown delivery tag $deliveryTag with result $result.") } } }