stop listening on the pending updates channels 10 times
This commit is contained in:
@@ -110,10 +110,5 @@ module.exports = DispatchManager = {
|
||||
_.times(number, function (shardNumber) {
|
||||
return DispatchManager.createDispatcher(RateLimiter, shardNumber).run()
|
||||
})
|
||||
|
||||
// run extra dispatchers on old queue while we migrate
|
||||
_.times(number, function () {
|
||||
return DispatchManager.createDispatcher(RateLimiter, 0).run()
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user