Skip to content

Commit

Permalink
Merge pull request #205 from avast/chore/change-log-level
Browse files Browse the repository at this point in the history
chore: core - publisher confirmations - change log level of the message in the case of unexpected delivery tag
  • Loading branch information
mi-char authored Aug 1, 2023
2 parents a3ac77f + 2c02800 commit ba57b6c
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down Expand Up @@ -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.")
}
}
}
Expand Down

0 comments on commit ba57b6c

Please sign in to comment.