sqsqs
SQSQS(Simple Quick SQS wrapper)
Usage
;// const Queue = require("sqsqs").default; ;; /* Send any number of string messages *//* Warning: the order of messages are not kept in the batch list! */await queue.send /* Receive specific number of string messages *//* it might wait until messages count reach that number or there are no remain messages in SQS queue */ /* ***received = [{ Body: "data1", ReceiptHandleId: ..., Id: ...},{ Body: "data2", ReceiptHandleId: ..., Id: ...}]*** */ /* parallel receive *//* the final message count could exceed the queueSize */ /* Delete Messages */await queue.deletereceived; /* Heartbeat Messages */await queue.heartbeatreceived;