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