nextrans-mq

NextransMQ

Instalation

npm install nextrans-mq

How to use

import MQ from 'nextrans-mq';

How Send Data

import MQ from 'nextrans-mq';

const mq = new MQ(process.env.RABBITMQ_HOST, process.env.RABBITMQ_CHANNEL_NAME);

mq.send({ data: 'Hellow world' });

How Consume Data

import MQ from 'nextrans-mq';

const mq = new MQ<MessageType>(process.env.RABBITMQ_HOST, process.env.RABBITMQ_CHANNEL_NAME);

mq.consume((payload: MessageType) => {
  callback(payload);
});

function callback(data: MessageType) {
  // do something
}

How Consume Broadcast Data

import MQ, { MQPayload } from 'nextrans-mq';

const mq = new MQ<MessageType>(process.env.RABBITMQ_HOST, process.env.RABBITMQ_CHANNEL_NAME);

function callback(data: MessageType) {
  // do something
}