To process a queue centrally. Making it possible to start and stop the process at any time.

This project started to deal with an issue when dispatching messages to SQS and Pub/Sub as the client SDK doesn't handle any asynchronous dispatch messages, when you haven't used await to wait for dispatch or when we are using it in another part of the code and the client has many messages.

To avoid lost messages, we need to create a set of messages and send them one by one as quickly as possible.

import { QueueProccessor } from "queue-proccessor";

async function myHandlerProccessMethod (data: number) {
  return new Promise((resolve) => {
    setTimeout(() => {
      resolve(data);
    }, 100);
  });
}
const queueProccessorNumber = new QueueProccessor<Object>(myHandlerProccessMethod);
queueProccessorNumber.add({id:1})
queueProccessorNumber.add({id:2})
queueProccessorNumber.start()

Start to proccess queue if has message. If is not, keep watch if the queue grows.

To push a new message to be handled

stop the proccess queue. It is possible to proccess keep running until the current handler message not finish to handle.

boolean: true if is proccessing. When stop is called, it is possible to proccess keep running until the current handler message not finish to handle.

boolean: true if is started

number : Current length of queue with no handler messages