fluent-logger
Advanced tools
Comparing version 0.4.1 to 0.4.2
@@ -34,2 +34,7 @@ 'use strict'; | ||
}; | ||
['addListener', 'on', 'once', 'removeListener', 'removeAllListeners'].forEach(function(attr, i){ | ||
appender[attr] = function(){ | ||
logSender[attr].apply(logSender, Array.prototype.slice.call(arguments)); | ||
}; | ||
}); | ||
return appender; | ||
@@ -36,0 +41,0 @@ } |
@@ -105,3 +105,5 @@ 'use strict'; | ||
self._socket = null; | ||
self._eventEmitter.emit('error', err); | ||
if( self._eventEmitter.listeners('error').length > 0 ){ | ||
self._eventEmitter.emit('error', err); | ||
} | ||
} | ||
@@ -108,0 +110,0 @@ }); |
{ | ||
"name": "fluent-logger", | ||
"version": "0.4.1", | ||
"version": "0.4.2", | ||
"main": "./lib/index.js", | ||
@@ -5,0 +5,0 @@ "scripts": { |
@@ -65,2 +65,17 @@ # fluent-logger for Node.js | ||
You can handle inner events such as 'error' it is raised when fluentd | ||
is down. | ||
var log4js = require('log4js'); | ||
var appender = require('fluent-logger').support.log4jsAppender('mytag', { | ||
host: 'localhost', | ||
port: 24224, | ||
timeout: 3.0 | ||
}); | ||
appender.on('error', function(err) { | ||
// Handle err object | ||
console.log(err); | ||
}); | ||
log4js.addAppender(appender); | ||
## License | ||
@@ -67,0 +82,0 @@ |
@@ -42,3 +42,38 @@ var expect = require('chai').expect; | ||
}); | ||
it('should not crash when fluentd is not running', function(done){ | ||
runServer(function(server, finish){ | ||
var appender = log4jsSupport.appender('debug', {port: server.port}); | ||
log4js.addAppender(appender); | ||
var logger = log4js.getLogger('mycategory'); | ||
logger.info('foo %s', 'bar'); | ||
setTimeout(function(){ | ||
finish(function(data){ | ||
expect(data[0].tag).to.be.equal('debug.INFO'); | ||
logger.info('foo %s', 'bar'); | ||
done(); | ||
}); | ||
}, 1000); | ||
}); | ||
}); | ||
it('should listen error event when fluentd is down', function(done){ | ||
runServer(function(server, finish){ | ||
var appender = log4jsSupport.appender('debug', {port: server.port}); | ||
appender.on('error', function(err) { | ||
expect(err.code).to.be.equal('ECONNREFUSED'); | ||
done(); | ||
}); | ||
log4js.addAppender(appender); | ||
var logger = log4js.getLogger('mycategory'); | ||
logger.info('foo %s', 'bar'); | ||
setTimeout(function(){ | ||
finish(function(data){ | ||
expect(data[0].tag).to.be.equal('debug.INFO'); | ||
logger.info('foo %s', 'bar'); | ||
}); | ||
}, 1000); | ||
}); | ||
}); | ||
}); | ||
}); |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
33701
12
605
90
2