fix NPE

reddec · Feb 21, 2020 · 547ccf0 · 547ccf0
1 parent 341144b
commit 547ccf0
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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)