Fix various bugs in the SQS. Implement SQS tests for the

jobs_ok.php/jobs_err.php workers.

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

1 files changed, 5 insertions, 3 deletions

diff --git a/plugins/jobs/drivers/sqs/consumer.go b/plugins/jobs/drivers/sqs/consumer.go
index 5d741358..9ce37543 100644
--- a/plugins/jobs/drivers/sqs/consumer.go
+++ b/plugins/jobs/drivers/sqs/consumer.go
@@ -262,9 +262,11 @@ func (j *JobConsumer) Push(ctx context.Context, jb *job.Job) error {
 }
 
 func (j *JobConsumer) handleItem(ctx context.Context, msg *Item) error {
-	// The new value for the message's visibility timeout (in seconds). Values range: 0
-	// to 43200. Maximum: 12 hours.
-	_, err := j.client.SendMessage(ctx, msg.pack(j.queueURL))
+	d, err := msg.pack(j.queueURL)
+	if err != nil {
+		return err
+	}
+	_, err = j.client.SendMessage(ctx, d)
 	if err != nil {
 		return err
 	}