From 547ccf0815a0e9711f67edb7139d93182e6d33fb Mon Sep 17 00:00:00 2001 From: Alexander Baryshnikov Date: Fri, 21 Feb 2020 19:26:23 +0800 Subject: [PATCH] fix NPE --- requeuer.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/requeuer.go b/requeuer.go index b074f91..99d8683 100644 --- a/requeuer.go +++ b/requeuer.go @@ -117,6 +117,9 @@ func (s *requeue) Requeue(original *amqp.Delivery) error { func (s *requeue) RequeueWithError(original *amqp.Delivery, err error) error { if err != nil { + if original.Headers == nil { + original.Headers = make(amqp.Table) + } original.Headers[LastErrorHeader] = err.Error() } return s.Requeue(original)