0.0.2 • Published 9 years ago
amqp-log v0.0.2
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 beinfo
,warn
,debug
orerror
.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
.