Close Heartbeat Queue
continuous-integration/drone/pr Build is failing Details

This commit is contained in:
Sarah Jamie Lewis 2023-04-03 14:49:45 -07:00
parent 4d81529ce2
commit 7107ad1eaa
1 changed files with 2 additions and 0 deletions

View File

@ -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
}
}