From 05b986408618c1cbd7491bd7b5cf689c3fb143e0 Mon Sep 17 00:00:00 2001 From: zeripath Date: Tue, 21 Jan 2020 12:02:25 +0000 Subject: [PATCH] Update queue_redis.go (#9911) --- 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 14e68937a..7d3efb9cf 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")