Skip to content

Commit 546a6ee

Browse files
author
Marcos Reyes
committed
Merge pull request #166 from telefonicaid/feature/configurableLogFlushing
ADD Flag to switch the log flushing on and off
2 parents 4892512 + d028066 commit 546a6ee

File tree

2 files changed

+14
-1
lines changed

2 files changed

+14
-1
lines changed

lib/configBase.js

+13
Original file line numberDiff line numberDiff line change
@@ -224,6 +224,12 @@ exports.consumer.logger.inspectDepth = 1;
224224
*/
225225
exports.consumer.logger.exitOnLogError = false;
226226

227+
/**
228+
* Flush Each Message
229+
* true = the logger will flush the buffer to file each time a new message arrives
230+
* false = the logger will lazily write messages to disk
231+
*/
232+
exports.consumer.logger.flushEachMessage = true;
227233

228234
/*
229235
Console.
@@ -280,6 +286,13 @@ exports.listener.logger.inspectDepth = 1;
280286
exports.listener.logger.exitOnLogError = false;
281287

282288

289+
/**
290+
* Flush Each Message
291+
* true = the logger will flush the buffer to file each time a new message arrives
292+
* false = the logger will lazily write messages to disk
293+
*/
294+
exports.listener.logger.flushEachMessage = true;
295+
283296

284297
/*
285298
Console.

lib/logger.js

+1-1
Original file line numberDiff line numberDiff line change
@@ -198,7 +198,7 @@ function newLogger() {
198198
var message = createLogMessage.call(this, level, message, logObj).replace(/\n/g, '');
199199

200200
var tmpLogger = winstonLogger.log(level, message);
201-
if (tmpLogger.transports.file._stream)
201+
if (config.flushEachMessage && tmpLogger.transports.file._stream)
202202
tmpLogger.transports.file.flush();
203203
return tmpLogger;
204204
};

0 commit comments

Comments
 (0)