@qrvey/queue

Qrvey queue message

This is a library to use AWS SQS service or RabbitMQ to send messages to a different queues.

Installation

npm install @qrvey/queue-service

Require environment variables

AWS_ACCOUNT_ID //AWS AccountId to send SQS service
AWS_DEFAULT_REGION //AWS Region for SQS service
RABBITMQ_HOST //RabbitMQ host
RABBITMQ_USER //RabbitMQ user
RABBITMQ_PASSWORD //RabbitMQ password
RABBITMQ_PORT //RabbitMQ port
PLATFORM_TYPE //Platform type (possible value CONTAINER)

Usage

Sample usage

const { QueueService } = require("@qrvey/queue-service");

const queueName = "queueName";

const queueServiceClient = new QueueService();

const message = {
    company: "Qrvey",
    name: "John Doe",
};

(async () => {
    await queueServiceClient.connect();

    const res = await queueServiceClient.sendMessage(queueName, message);
    
    await queueServiceClient.disconnect();

    console.log("res: ", res);
})();