fixed queue is not flushed at re-connection

naomichi-y · Jun 7, 2016 · 730c282 · 730c282
1 parent 07b03a2
commit 730c282
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/sender.js b/lib/sender.js
@@ -110,10 +110,12 @@ FluentSender.prototype._connect = function(callback){
     });
     if (self.path) {
       self._socket.connect(self.path, function() {
+        self._flushSendQueue();
         callback();
       });
     } else {
       self._socket.connect(self.port, self.host, function() {
+        self._flushSendQueue();
         callback();
       });
     }