AMQP stream for Bunyan

AMQP stream for the Bunyan logger

Installation

$ npm install bunyan-amqp-logger

Usage

"use strict";

var bunyan = require('bunyan');
var bunyanamqp = require('bunyan-amqp-logger');

var amq_stream = bunyanamqp.createStream({
    login : 'admin',
    password : 'UbpdMksr0ons',
    exchange : {
        routingKey : 'logs'
    }
}).on('connect', function () {
    console.log("Connected to amqp");
}).on('close', function (e) {
    console.log("Closed connection to amqp");
}).on('error', console.log);


var log = bunyan.createLogger({
    name : 'example',
    streams : [{
        level : 'debug',
        stream : process.stdout
    }, {
        level : 'debug',
        type : 'raw',
        stream : amq_stream
    }]
});

Configuration

A raw bunyan stream can be created using the module createStream(options)method.

The options object accepts the following fields:

| Parameter | Type | Default | Description | | ------------- |:-------------:| -----:|-----:| | host | string | localhost | AMQP host | | port | number | 5672 | AMQP port | | vhost | string | / | AMQP virtual host | | login | string | guest | AMQP username | | password | string | guest | AMQP password | | sslEnable | boolean | false | Enable AMQP SSL | | sslKey | string | '' | AMQP SSL private key file path | | sslCert | string | '' | AMQP SSL certificate file path | | sslCA | string | '' | AMQP SSL CA file path | | sslRejectUnauthorized | boolean | true | Verify AMQP SSL certificate against CA | | exchange | object | undefined | AMQP exchange options | | level | string | info | Message level | | server | string | os.hostname() | Message source server | | application | string | process.title | Message source application | | pid | string | process.pid | Message pid | | tags | string array | ["bunyan"] | Message tags | | type | string | undefined | Message type | | bufferSize | number | 100 | Outstanding message buffer size | | messageFormatter | function | undefined | Optional message formatting function |

The exchange object accepts the following fields:

| Parameter | Type | Default | Description | | ------------- |:-------------:| -----:|-----:| | name | string | undefined | AMQP exchange name | | routingKey | string | message.level | AMQP message routing key | | properties | object | {} | AMQP exchange options |

Events

The stream will emit open, close and error events from the underlying AMQP connection.

Credits

This module is heavily based on bunyan-logstash-amqp.