fluent-logger - npm Package Compare versions

Comparing version 2.3.0 to 2.4.0

lib/sender.js

		@@ -25,2 +25,3 @@ 'use strict';
		this.ackResponseTimeout = options.ackResponseTimeout \|\| 190000; // Default is 190 seconds
		this.internalLogger = options.internalLogger \|\| console;
		this._timeResolution = options.milliseconds ? 1 : 1000;
		@@ -242,8 +243,8 @@ this._socket = null;
		self.on('error', function(error) {
		console.error('Fluentd error', error);
		console.info('Fluentd will reconnect after ' + self.reconnectInterval / 1000 + ' seconds');
		self.internalLogger.error('Fluentd error', error);
		self.internalLogger.info('Fluentd will reconnect after ' + self.reconnectInterval / 1000 + ' seconds');
		setTimeout(function() {
		console.info("Fluentd is reconnecting...");
		self.internalLogger.info("Fluentd is reconnecting...");
		self._connect(function() {
		console.info('Fluentd reconnection finished!!');
		self.internalLogger.info('Fluentd reconnection finished!!');
		});
		@@ -250,0 +251,0 @@ }, self.reconnectInterval);

package.json

README.md

		@@ -238,2 +238,7 @@ # fluent-logger for Node.js

		internalLogger

		Set internal logger object for FluentLogger. Use `console` by default.
		This logger requires `info` and `error` method.

		## License
		@@ -240,0 +245,0 @@

test/test.sender.js

		@@ -67,3 +67,32 @@ var expect = require('chai').expect;

		it('should log error when connection fails w/ internal logger', function(done) {
		var logger = {
		buffer: {
		info: [],
		error: []
		},
		info: function(message) {
		this.buffer.info.push(message);
		},
		error: function(message) {
		this.buffer.error.push(message);
		}
		};
		var s = new sender.FluentSender('debug', {
		host: 'localhost',
		port: 65535,
		internalLogger: logger
		});
		s._setupErrorHandler();
		s.on('error', function(err) {
		expect(logger.buffer.info).to.have.lengthOf(1);
		expect(logger.buffer.info[0]).to.be.equal('Fluentd will reconnect after 600 seconds');
		expect(logger.buffer.error).to.have.lengthOf(1);
		expect(logger.buffer.error[0]).to.be.equal('Fluentd error');
		done();
		});
		s.emit('test connection error', { message: 'foobar' });
		});


		it('should assure the sequence.', function(done){
		@@ -70,0 +99,0 @@ runServer({}, function(server, finish){

New alerts