From 18be356b6205b7d990afd10bcb8cc68151cd0dcd Mon Sep 17 00:00:00 2001 From: urso Date: Tue, 19 Apr 2016 01:25:48 +0200 Subject: [PATCH] topbeat close publisher.Client on stop --- topbeat/beater/topbeat.go | 1 + 1 file changed, 1 insertion(+) diff --git a/topbeat/beater/topbeat.go b/topbeat/beater/topbeat.go index 3b896a8681ba..34f87e4f38c1 100644 --- a/topbeat/beater/topbeat.go +++ b/topbeat/beater/topbeat.go @@ -172,4 +172,5 @@ func (tb *Topbeat) Cleanup(b *beat.Beat) error { func (t *Topbeat) Stop() { logp.Info("Send stop signal to topbeat main loop") close(t.done) + t.events.Close() }