From 8cb9b2f016f0a5c1aa3e907d4d6640c3c9ba5d57 Mon Sep 17 00:00:00 2001 From: zeripath Date: Tue, 21 Jan 2020 12:50:27 +0000 Subject: [PATCH] Update queue_redis.go (#9910) Co-authored-by: Lunny Xiao --- modules/queue/queue_redis.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/modules/queue/queue_redis.go b/modules/queue/queue_redis.go index 14e68937a5b..7d3efb9cff7 100644 --- a/modules/queue/queue_redis.go +++ b/modules/queue/queue_redis.go @@ -84,11 +84,12 @@ func NewRedisQueue(handle HandlerFunc, cfg, exemplar interface{}) (Queue, error) boostWorkers: config.BoostWorkers, maxNumberOfWorkers: config.MaxWorkers, }, - queueName: config.QueueName, - exemplar: exemplar, - closed: make(chan struct{}), - workers: config.Workers, - name: config.Name, + queueName: config.QueueName, + exemplar: exemplar, + closed: make(chan struct{}), + terminated: make(chan struct{}), + workers: config.Workers, + name: config.Name, } if len(dbs) == 0 { return nil, errors.New("no redis host specified")