Update redis.js

This commit is contained in:
wadecha 2017-03-07 11:24:11 +08:00 committed by GitHub
parent 2d415eca10
commit e5777d4cbd

View File

@ -1,19 +1,19 @@
'use strict';
var layouts = require('../layouts');
var redis = require('redis');
var util = require('util');
let layouts = require('../layouts');
let redis = require('redis');
let util = require('util');
function redisAppender(host, port, pass, channel, layout) {
layout = layout || layouts.messagePassThroughLayout;
var redisClient = redis.createClient(port, host, { auth_pass: pass });
const 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);
const message = layout(loggingEvent);
redisClient.publish(channel, message, function (err) {
if (err) {
console.error('log4js.redisAppender - %s:%p Error: %s', host, port, util.inspect(err));
@ -23,7 +23,7 @@ function redisAppender(host, port, pass, channel, layout) {
}
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);
}