From 9ef8ea8f7d0b6d6915fd6276d80d18e50011cc3d Mon Sep 17 00:00:00 2001
From: Johan de Klerk <johan@shiplogic.com>
Date: Wed, 21 Jun 2023 10:01:04 +0200
Subject: [PATCH] Added sqs delay
---
sqs/sqs.go | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/sqs/sqs.go b/sqs/sqs.go
index 369c220..b930879 100644
--- a/sqs/sqs.go
+++ b/sqs/sqs.go
@@ -107,6 +107,10 @@ func SendSQSMessage(msgr Messenger, objectToSend interface{}, currentRequestID *
if isDebug {
go func() {
+ if msgr.DelaySeconds != nil {
+ delay := *msgr.DelaySeconds
+ time.Sleep( time.Second * time.Duration(delay))
+ }
resty.New().R().
SetBody(objectToSend).
Post("http://127.0.0.1:3000/sqs/" + sqsType)
--
GitLab