From fbb575b2b537cc1037b5688987f5451801712fd7 Mon Sep 17 00:00:00 2001 From: zeripath Date: Tue, 21 Jan 2020 07:35:59 +0000 Subject: [PATCH] Update queue_redis.go --- 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 14e68937a5b88..7d3efb9cff7be 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")