Fix queue shutdown
continuous-integration/drone/pr Build is passing
Details
continuous-integration/drone/pr Build is passing
Details
This commit is contained in:
parent
7107ad1eaa
commit
51f85ea619
|
@ -24,7 +24,7 @@ func (cr *heartbeat) Id() PluginID {
|
|||
|
||||
func (a heartbeat) Shutdown() {
|
||||
a.breakChan <- true
|
||||
a.bus.Shutdown()
|
||||
a.queue.Shutdown()
|
||||
}
|
||||
|
||||
func (a *heartbeat) run() {
|
||||
|
|
Loading…
Reference in New Issue