go-pkg/asynq
2
0
Fork 0
mirror of https://github.com/hibiken/asynq.git synced 2024-12-25 07:12:17 +08:00
Code Issues Projects Releases Wiki Activity

Add log messages around Server.Quiet

Browse Source
This commit is contained in:
Ken Hibino 2020-05-16 07:12:08 -07:00
parent 556b2103fe
commit 210b026b01
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server.go
View File

@ -422,6 +422,8 @@ func (srv *Server) Stop() {
// Quiet signals the server to stop pulling new tasks off queues. // Quiet signals the server to stop pulling new tasks off queues.
// Quiet should be used before stopping the server. // Quiet should be used before stopping the server.
func (srv *Server) Quiet() { func (srv *Server) Quiet() {
srv.logger.Info("Stopping processor")
srv.processor.stop() srv.processor.stop()
srv.ss.SetStatus(base.StatusQuiet) srv.ss.SetStatus(base.StatusQuiet)
srv.logger.Info("Processor stopped")
} }