Merge pull request #136 from sphansekar-cci/reconnect-and-flush-on-re…

…connect #135 Error handling and flushing message on reconnection.
fluent · Feb 15, 2019 · 1623b0a · 1623b0a
2 parents 7f75c65 + 4aa6354
commit 1623b0a
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/lib/sender.js b/lib/sender.js
@@ -451,6 +451,7 @@ class FluentSender {
       let timeoutId = setTimeout(() => {
         this.internalLogger.info('Fluentd is reconnecting...');
         this._connect(() => {
+          this._flushSendQueue()
           this.internalLogger.info('Fluentd reconnection finished!!');
         });
       }, this.reconnectInterval);

diff --git a/lib/winston.js b/lib/winston.js
@@ -32,6 +32,7 @@ module.exports = class FluentTransport extends Transport {
     super(options);
     this.name = 'fluent';
     this.sender = new FluentSender(tag, options);
+    this.sender._setupErrorHandler();
   }
 
   log(info, callback) {