core: fix WorkerService implementation

This commit is contained in:
undefined committed 2021-08-11 21:54:23 +08:00
1 parent 4356f17ef8
commit 10bad169cf
1 file changed
+2
+2
View File
@@ -60,6 +60,8 @@ class Consumer {
class WorkerService implements BaseService {
private handlers: Record<string, Function> = {};
public started = true;
public start = () => { };
public consumer = new Consumer(
{ type: 'schedule', subType: { $in: Object.keys(this.handlers) } },
async (doc) => {