@n0tify/rmq

RabbitMQ transport for @n0tify libs.

Allows to communicate via RabbitMQ message queues.

Options

RmqTransport inherits all parameters from amqplib connection params and includes queue that defines which queue should be used for message subscribe/push.

Usage

import { RmqTransport } from '@n0tify/rmq';
import { Client } from '@n0tify/client';

...

const transport = new RmqTransport({
  hostname: 'localhost',
  port: 5672,
  username: 'guest',
  password: 'guest',
  vhost: '/',
  queue: 'message_queue'
});