bunyan-rabbitmq-stream

RabbitMQ WriteStream for Bunyan

Docs

const RabbitMQStream = require('bunyan-rabbitmq-stream').stream;

const logStream = new RabbitmqLogStream(options);
const bunyan = require('bunyan');

const log = bunyan.createLogger({
  name: 'logger',
  stream: logStream,
});

logStream.connect()
  .then(() => console.log('rabbitmq log stream connected'));

Options

• @param {object} options
• @param {string} optinos.uri rabbitmq connection string
• @param {broker.node.connection} options.connection use an existing connection
• @param {string} options.exchangeName rabbitmq exchange name
• @param {string} options.namePrefix consumer queue name prefix
• @param {string} options.routingKey log default routing key
• @param {string} options.exchangeType @default topic