There is an incorrect casting in the wrapped queue. Fix #16071 Signed-off-by: Andrew Thornton <art27@cantab.net>tags/v1.15.0-rc1
@@ -188,7 +188,7 @@ func (q *PersistableChannelUniqueQueue) Run(atShutdown, atTerminate func(func()) | |||
go q.internal.Run(func(_ func()) {}, func(_ func()) {}) | |||
go func() { | |||
_ = q.internal.Flush(0) | |||
log.Debug("LevelUniqueQueue: %s flushed so shutting down", q.internal.(*LevelQueue).Name()) | |||
log.Debug("LevelUniqueQueue: %s flushed so shutting down", q.internal.(*LevelUniqueQueue).Name()) | |||
q.internal.(*LevelUniqueQueue).Shutdown() | |||
GetManager().Remove(q.internal.(*LevelUniqueQueue).qid) | |||
}() |