Skip to content

Commit a3ac77f

Browse files
authored
Merge pull request #204 from avast/chore/pub_conf_error_message
chore: core - publisher confirmations - add more details to the error message in the case of unexpected delivery tag
2 parents 8f66761 + 93c397e commit a3ac77f

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

core/src/main/scala/com/avast/clients/rabbitmq/publisher/PublishConfirmsRabbitMQProducer.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -107,7 +107,8 @@ class PublishConfirmsRabbitMQProducer[F[_], A: ProductConverter](name: String,
107107
} else {
108108
confirmationCallbacks.get(deliveryTag) match {
109109
case Some(callback) => callback.complete(result)
110-
case None => logger.plainError(s"Received confirmation for unknown delivery tag $deliveryTag. That is unexpected state.")
110+
case None =>
111+
logger.plainError(s"Received confirmation for unknown delivery tag $deliveryTag with result $result. That is unexpected state.")
111112
}
112113
}
113114
}

0 commit comments

Comments
 (0)