Redis SQS is alternate of AWS SQS and RabbitMQ
set DEBUG=Redis_SQS*
await RedisSQS.init(
{ port: 6379,
host: "127.0.0.1",
auth_pass: "password"
});
Send Message to Queue
/**
*
* @param {string} queueName
* @param {string|string[]} data
* @returns {Promise<void>}
*/
RedisSQS.sendMessage(queueName, data): Promise<void>;
Example:
await RedisSQS.sendMessage("queueName","any kind of data");
Consume an Queue
/**
*
* @param {string} queueName
* @param {function(string|string[]):Promise<void>} handler
* @param {number=} batchSize - Default 1
*/
RedisSQS.consumeMessages(queueName,handler,batchSize=1);
Example:
await RedisSQS.consumeMessages("queuename",(data)=>{console.log(data)},1);
Stop Consume an Queue
/**
*
* @param {string} queueName
*/
RedisSQS.stopConsumeMessage(queueName);
Example:
await RedisSQS.stopConsumeMessage("queuename");