From e7db2b99b219968b5d541f28d0b144d9188f84b9 Mon Sep 17 00:00:00 2001 From: Dusan Malusev Date: Tue, 11 Jun 2024 14:15:58 +0200 Subject: [PATCH] Fixing issue with RetryHandler Signed-off-by: Dusan Malusev --- consumer/handler.go | 1 + 1 file changed, 1 insertion(+) diff --git a/consumer/handler.go b/consumer/handler.go index 4cfe14d..40aa398 100644 --- a/consumer/handler.go +++ b/consumer/handler.go @@ -75,6 +75,7 @@ func (h retryHandler[T]) retry(err error, delivery *amqp091.Delivery) error { _, ok := delivery.Headers[retryHeader] if !ok { + delivery.Headers = make(amqp091.Table) delivery.Headers[retryHeader] = int64(h.retryCount) }