sqs producer improvements

This commit is contained in:
YevhenBondarenko 2020-10-30 13:29:48 +02:00 committed by Andrew Shvayka
parent 938588c5bc
commit eeec6bac9f

View File

@ -52,11 +52,13 @@ function AwsSqsProducer() {
queueUrls.set(responseTopic, responseQueueUrl); queueUrls.set(responseTopic, responseQueueUrl);
} }
let msgId = uuid();
let params = { let params = {
MessageBody: msgBody, MessageBody: msgBody,
QueueUrl: responseQueueUrl, QueueUrl: responseQueueUrl,
MessageGroupId: 'js_eval', MessageGroupId: msgId,
MessageDeduplicationId: uuid() MessageDeduplicationId: msgId
}; };
return new Promise((resolve, reject) => { return new Promise((resolve, reject) => {