Merge pull request #59 from jumptrading/monitor-test-failure

monitor: Flush after subscribing
jumptrading · Apr 3, 2018 · 1c065ba · 1c065ba
2 parents 1b80854 + f568c8d
commit 1c065ba
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/monitor/monitor.go b/monitor/monitor.go
@@ -50,6 +50,9 @@ func Start(conf *config.Config) (_ *Monitor, err error) {
 	if err != nil {
 		return nil, fmt.Errorf("NATS: failed to subscribe: %v", err)
 	}
+	if err := m.nc.Flush(); err != nil {
+		return nil, fmt.Errorf("NATS: failed to flush: %v", err)
+	}
 
 	m.wg.Add(1)
 	go m.serveHTTP()