|
|
|
@ -67,6 +67,7 @@ class WorkerDirective extends Directive {
|
|
|
|
|
async handle(app, argv) {
|
|
|
|
|
const [ worker_name ] = argv
|
|
|
|
|
const config = this.config()
|
|
|
|
|
const redis_config = this.configs.get('redis')
|
|
|
|
|
const worker_config = config.workers[worker_name]
|
|
|
|
|
const queue_workers = {}
|
|
|
|
|
|
|
|
|
@ -90,7 +91,7 @@ class WorkerDirective extends Directive {
|
|
|
|
|
|
|
|
|
|
throw e
|
|
|
|
|
}
|
|
|
|
|
})
|
|
|
|
|
}, { connection: redis_config })
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
await new Promise(res => {
|
|
|
|
|