diff options
Diffstat (limited to 'modules/queue/queue_disk_channel.go')
| -rw-r--r-- | modules/queue/queue_disk_channel.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/modules/queue/queue_disk_channel.go b/modules/queue/queue_disk_channel.go index 433435c301..801fd8a122 100644 --- a/modules/queue/queue_disk_channel.go +++ b/modules/queue/queue_disk_channel.go @@ -75,10 +75,10 @@ func NewPersistableChannelQueue(handle HandlerFunc, cfg, exemplar interface{}) ( BatchLength: config.BatchLength, BlockTimeout: 1 * time.Second, BoostTimeout: 5 * time.Minute, - BoostWorkers: 5, - MaxWorkers: 6, + BoostWorkers: 1, + MaxWorkers: 5, }, - Workers: 1, + Workers: 0, Name: config.Name + "-level", }, DataDir: config.DataDir, |