1.1.1 • Published 2 months ago
nextrans-mq v1.1.1
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
}