flush every message, not just first 300

nyaruka · Aug 21, 2017 · 5495a48 · 5495a48
1 parent b330039
commit 5495a48
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/librato/librato.go b/librato/librato.go
@@ -57,12 +57,16 @@ func (c *Sender) Start() {
 		for {
 			select {
 			case <-c.stop:
-				c.flush(1000)
+				for len(c.buffer) > 0 {
+					c.flush(250)
+				}
 				logrus.WithField("comp", "librato").Info("stopped")
 				return
 
 			case <-time.After(c.timeout * time.Second):
-				c.flush(300)
+				for i := 0; i < 4; i++ {
+					c.flush(250)
+				}
 			}
 		}
 	}()