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:09:18 +08:00 committed by GitHub
parent 9096d57d82
commit 2ee2098fc7
1 changed files with 24 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
lib/appenders/redis.js
View File

@ -5,33 +5,33 @@ var redis = require('redis');
var util = require('util');
function redisAppender(host, port, pass, channel, layout) {
layout = layout || layouts.messagePassThroughLayout;
var 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)
);
}
});
return function (loggingEvent) {
var message = layout(loggingEvent);
redisClient.publish(channel, message, function (err) {
if (err) {
console.error(
'log4js.redisAppender - %s:%p Error: %s', host, port, util.inspect(err)
);
}
});
};
layout = layout || layouts.messagePassThroughLayout;
var 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)
);
}
});
return function (loggingEvent) {
var message = layout(loggingEvent);
redisClient.publish(channel, message, function (err) {
if (err) {
console.error(
'log4js.redisAppender - %s:%p Error: %s', host, port, util.inspect(err)
);
}
});
};
}
function configure(config) {
var 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';
var 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';