From 7107ad1eaa91709d91c5699633599c299910a7b2 Mon Sep 17 00:00:00 2001 From: Sarah Jamie Lewis Date: Mon, 3 Apr 2023 14:49:45 -0700 Subject: [PATCH] Close Heartbeat Queue --- app/plugins/heartbeat.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/app/plugins/heartbeat.go b/app/plugins/heartbeat.go index 9932497..bd75f4b 100644 --- a/app/plugins/heartbeat.go +++ b/app/plugins/heartbeat.go @@ -24,6 +24,7 @@ func (cr *heartbeat) Id() PluginID { func (a heartbeat) Shutdown() { a.breakChan <- true + a.bus.Shutdown() } func (a *heartbeat) run() { @@ -35,6 +36,7 @@ func (a *heartbeat) run() { a.bus.Publish(event.NewEvent(event.Heartbeat, map[event.Field]string{})) continue case <-a.breakChan: + log.Debugf("shutting down heartbeat plugin") return } }