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 80c9e8d commit 8edb889Copy full SHA for 8edb889
modules/task/queue_channel.go
@@ -42,6 +42,7 @@ func (c *ChannelQueue) Push(task *models.Task) error {
42
return nil
43
}
44
45
+// Stop stop the queue
46
func (c *ChannelQueue) Stop() {
47
close(c.queue)
48
modules/task/queue_redis.go
@@ -124,6 +124,7 @@ func (r *RedisQueue) Push(task *models.Task) error {
124
return r.client.RPush(r.queueName, bs).Err()
125
126
127
128
func (r *RedisQueue) Stop() {
129
r.closeChan <- true
130
0 commit comments