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);

mq.consumeBroadcast((payload: MQPayload<MessageType>) => {
  const { messageId, timestamp, data } = payload;

  const isDataExists = await Model.findOne({ where: { message_id: messageId, message_timestamp: timestamp } });

  if(!isDataExists) {
    callback(data);
  }
});

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