Add headers support to the jobs protocol

Signed-off-by: Valery Piashchynski <[email protected]>

1 files changed, 2 insertions, 1 deletions

diff --git a/plugins/jobs/drivers/sqs/item.go b/plugins/jobs/drivers/sqs/item.go
index cd2f6104..a761d6bd 100644
--- a/plugins/jobs/drivers/sqs/item.go
+++ b/plugins/jobs/drivers/sqs/item.go
@@ -140,9 +140,10 @@ func (i *Item) Nack() error {
 	return nil
 }
 
-func (i *Item) Requeue(delay int64) error {
+func (i *Item) Requeue(headers map[string][]string, delay int64) error {
 	// overwrite the delay
 	i.Options.Delay = delay
+	i.Headers = headers
 	select {
 	case i.Options.requeueCh <- i:
 		return nil