diff options
Diffstat (limited to 'modules/queue/queue_redis.go')
| -rw-r--r-- | modules/queue/queue_redis.go | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/modules/queue/queue_redis.go b/modules/queue/queue_redis.go index 14e68937a5..7d3efb9cff 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") |