The draining process is not terminated via context.WithTimeout. https://github.com/natureglobal/firequeue/blob/v0.0.7/firequeue.go#L179-L188 I suggest draining process timeout support.