From 730c28261aa2229ec71608dce44ea0a306a88b24 Mon Sep 17 00:00:00 2001
From: naomichi-y <n.yamakita@gmail.com>
Date: Tue, 7 Jun 2016 14:50:22 +0900
Subject: [PATCH] fixed queue is not flushed at re-connection

---
 lib/sender.js | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/lib/sender.js b/lib/sender.js
index 5d7857a..726857c 100644
--- 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();
       });
     }