core: fix error when pid!==displayId

This commit is contained in:
undefined committed 2021-06-24 11:54:07 +08:00
1 parent 7fd31995ab
commit 37ce0a4f66
3 files changed
+21 -16

No files matched your search

+8 -3
View File
@@ -66,9 +66,14 @@ class WorkerService implements BaseService {
public start() {
this.consumer = new Consumer(
{ type: 'schedule', subType: { $in: Object.keys(this.handlers) } },
(doc) => {
logger.debug('Worker task: %o', doc);
return this.handlers[doc.subType](doc);
async (doc) => {
try {
logger.debug('Worker task: %o', doc);
await this.handlers[doc.subType](doc);
} catch (e) {
logger.error('Worker task fail: ', e);
logger.error('%o', doc);
}
},
false,
);