dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor JavaScript Executor AWS SQS queue

Browse Source
This commit is contained in:
Vladyslav_Prykhodko 2022-07-08 15:25:00 +03:00
parent b4592f5f92
commit 60853dd5d6
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
msa/js-executor/queue/awsSqsTemplate.ts
View File

@ -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<any> {