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

#135 Error handling and flushing message on reconnection.

Author: okkez

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);

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) {