amqp-log

Stream logs through amqp.

Each log call generates an amqp message that is sent using the fanout type. Therefore the log messages do not require acknowledgement.

The log messages are sent to the exchange defined in the options The routing key under which the messages are sent is log.<type>[.<source>], where:

• type is the logging type, and can be info, warn, debug or error.
• source is just used if a source option is given in the AmqpLog constructor, and is just a string used to distinguish which module or library generated the logs.

Usage

Import the amqp-log module (returns a class AmqpLog), and instantiate it, passing the desired options as constructor argument:

var amqpOptions = {
  "connection": {
  	"hostname": "localhost",
    "port": 5672
  }
};

var AmqpLog = require("amqp-log");
var log = new AmqpLog(options);

log.info('this is an info message');
log.warn('this is a warn message');
log.debug('this is a debug message');
log.error('this is an error message');

If no parameter is given in the constructor, the hostname localhost and port 5672 are used by default.

Available Options

The options in [] are optional:

• connection {Object} Connection options for amqp.
• [source] {String} Name to be appended to the routing key of the amqp message.
• [exchange] {String} Name of the amqp exchange. Default: logs.