We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 59db366 commit 0241103Copy full SHA for 0241103
queue.go
@@ -87,7 +87,9 @@ func (q *Queue) Start() {
87
// Shutdown stops all queues.
88
func (q *Queue) Shutdown() {
89
q.stopOnce.Do(func() {
90
- q.worker.Shutdown()
+ if err := q.worker.Shutdown(); err != nil {
91
+ q.logger.Error(err)
92
+ }
93
close(q.quit)
94
})
95
}
@@ -123,7 +125,9 @@ func (q *Queue) work() {
123
125
124
126
}()
127
q.logger.Infof("start the worker num: %d", num)
- q.worker.Run(q.quit)
128
+ if err := q.worker.Run(q.quit); err != nil {
129
130
131
q.logger.Infof("stop the worker num: %d", num)
132
133
if err := q.worker.AfterRun(); err != nil {
0 commit comments