Fixing issue with RetryHandler

Signed-off-by: Dusan Malusev <dusan@dusanmalusev.dev>
nano-interactive · Jun 11, 2024 · e7db2b9 · e7db2b9
1 parent 031c76a
commit e7db2b9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)
 	}