Skip to content

Commit 1cace4e

Browse files
authored
Merge pull request #144 from avast/FixPoisonnedHeaders
Poisoned message handler: fix merging of headers
2 parents 474503a + a1d5cb5 commit 1cace4e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

extras/src/main/scala/com/avast/clients/rabbitmq/extras/PoisonedMessageHandler.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,8 @@ private[rabbitmq] class DefaultPoisonedMessageHandler[F[_]: Sync, A](maxAttempts
2929

3030
private def republishDelivery(delivery: Delivery[A], newHeaders: Map[String, AnyRef]): F[DeliveryResult] = {
3131
// get current attempt no. from passed headers with fallback to original (incoming) headers - the fallback will most likely happen
32-
// but we're giving the programmer chance to programatically _pretend_ lower attempt number
33-
val attempt = (newHeaders ++ delivery.properties.headers)
32+
// but we're giving the programmer chance to programmatically _pretend_ lower attempt number
33+
val attempt = (delivery.properties.headers ++ newHeaders)
3434
.get(RepublishCountHeaderName)
3535
.flatMap(v => Try(v.toString.toInt).toOption)
3636
.getOrElse(0) + 1

0 commit comments

Comments
 (0)