archive-gh-me/log4js-node
1
0
Fork 0
mirror of https://github.com/log4js-node/log4js-node.git synced 2025-12-08 19:26:01 +00:00
Code Issues Projects Releases Wiki Activity

Update redis.js

Browse Source
This commit is contained in:
wadecha 2017-03-07 10:19:16 +08:00 committed by GitHub
parent 2ee2098fc7
commit ad1e220ba9
1 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
lib/appenders/redis.js
View File

@ -6,36 +6,32 @@ var util = require('util');
function redisAppender(host, port, pass, channel, layout) {
layout = layout || layouts.messagePassThroughLayout;
var redisClient = redis.createClient(port, host, {auth_pass: pass});
let redisClient = redis.createClient(port, host, {auth_pass: pass});
redisClient.on('error', function (err) {
if (err) {
console.error(
'log4js.redisAppender - %s:%p Error: %s', host, port, util.inspect(err)
);
console.error('log4js.redisAppender - %s:%p Error: %s', host, port, util.inspect(err));
}
});
return function (loggingEvent) {
var message = layout(loggingEvent);
let message = layout(loggingEvent);
redisClient.publish(channel, message, function (err) {
if (err) {
console.error(
'log4js.redisAppender - %s:%p Error: %s', host, port, util.inspect(err)
);
console.error('log4js.redisAppender - %s:%p Error: %s', host, port, util.inspect(err));
}
});
};
}
function configure(config) {
var layout, host, port, pass, channel;
let layout, host, port, pass, channel;
if (config.layout) {
layout = layouts.layout(config.layout.type, config.layout);
}
host = config.host ? config.host : '127.0.0.1';
port = config.port ? config.port : 6379;
pass = config.pass ? config.pass : '';
channel = config.channel ? config.channel : 'log';
return redisAppender(host, port, pass, channel, layout);
port = config.port ? config.port : 6379;
pass = config.pass ? config.pass : '';
channel = config.channel ? config.channel : 'log';
return redisAppender(host, port, pass, channel, layout);
}
exports.appender = redisAppender;