From 60853dd5d6319e45f268dd741d5c0bc6a54d8c16 Mon Sep 17 00:00:00 2001 From: Vladyslav_Prykhodko Date: Fri, 8 Jul 2022 15:25:00 +0300 Subject: [PATCH] Refactor JavaScript Executor AWS SQS queue --- msa/js-executor/queue/awsSqsTemplate.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/msa/js-executor/queue/awsSqsTemplate.ts b/msa/js-executor/queue/awsSqsTemplate.ts index c48b18050a..259d285cf2 100644 --- a/msa/js-executor/queue/awsSqsTemplate.ts +++ b/msa/js-executor/queue/awsSqsTemplate.ts @@ -90,12 +90,12 @@ export class AwsSqsTemplate implements IQueue { const params: ReceiveMessageRequest = { MaxNumberOfMessages: 10, QueueUrl: this.requestQueueURL, - WaitTimeSeconds: Math.round(this.pollInterval / 10) + WaitTimeSeconds: Math.ceil(this.pollInterval / 10) }; - this.timer = setTimeout(() => {this.processMessage(messageProcessor, params)}, this.pollInterval); + this.timer = setTimeout(() => {this.getAndProcessMessage(messageProcessor, params)}, this.pollInterval); } - private async processMessage(messageProcessor: JsInvokeMessageProcessor, params: ReceiveMessageRequest) { + private async getAndProcessMessage(messageProcessor: JsInvokeMessageProcessor, params: ReceiveMessageRequest) { const messagesResponse: ReceiveMessageResult = await this.sqsClient.send(new ReceiveMessageCommand(params)); const messages = messagesResponse.Messages; @@ -120,7 +120,7 @@ export class AwsSqsTemplate implements IQueue { this.logger.error("Failed to delete messages from queue.", err.message); } } - this.timer = setTimeout(() => {this.processMessage(messageProcessor, params)}, this.pollInterval); + this.timer = setTimeout(() => {this.getAndProcessMessage(messageProcessor, params)}, this.pollInterval); } async send(responseTopic: string, scriptId: string, rawResponse: Buffer, headers: any): Promise {