diff options
| author | zeripath <art27@cantab.net> | 2020-01-21 12:50:27 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-01-21 12:50:27 +0000 |
| commit | 8cb9b2f016f0a5c1aa3e907d4d6640c3c9ba5d57 (patch) | |
| tree | 6ad8ba801c3ce7d0125c1097d1d8855dc9f9e459 /modules/queue | |
| parent | 8da863ed1551b35eaee2062f7f436ac0fc1703a8 (diff) | |
| download | gitea-8cb9b2f016f0a5c1aa3e907d4d6640c3c9ba5d57.tar.gz gitea-8cb9b2f016f0a5c1aa3e907d4d6640c3c9ba5d57.zip | |
Update queue_redis.go (#9910)
Co-authored-by: Lunny Xiao <xiaolunwen@gmail.com>
Diffstat (limited to 'modules/queue')
| -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") |