sqsqs v0.2.8

sqsqs

SQSQS(Simple Quick SQS wrapper)

Usage

import Queue from 'sqsqs';
// const Queue = require("sqsqs").default;

const awsConfig = {
  apiVersion: '2012-01-01',
  region: 'ap-northeast-2',
};
const queue = new Queue({ QueueUrl: string, }, awsConfig);

const data1 = "data1"
const data2 = "data2"

/* Send any number of string messages */
/* Warning: the order of messages are not kept in the batch list! */
await queue.send([data1, data2])

/* Receive specific number of string messages */
/* it might wait until messages count reach that number or there are no remain messages in SQS queue */
let queueSize = 50
let received = await queue.receive(queueSize)

/* ***
received = [{
  Body: "data1",
  ReceiptHandleId: ...,
  Id: ...
},{
  Body: "data2",
  ReceiptHandleId: ...,
  Id: ...
}]
*** */

/* parallel receive */
/* the final message count could exceed the queueSize */
let concurrency = 10
let received = await queue.receive(queueSize, concurrency)


/* Delete Messages */
await queue.delete(received);

/* Heartbeat Messages */
await queue.heartbeat(received);