diff --git a/sqs/sqs.go b/sqs/sqs.go index 369c220906d5da06d7844d8999d564d4674cfd21..b9308799ff4a5044cd6400be314324218436c709 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)