1
This commit is contained in:
parent
e7294a5465
commit
d82546500b
@ -214,15 +214,24 @@ class DbEventProcess extends BaseService {
|
||||
}
|
||||
|
||||
async process(row) {
|
||||
const logHead = this.getInstanceName() + ' process: ';
|
||||
if (!this.eventHandle) {
|
||||
return false;
|
||||
}
|
||||
while (true) {
|
||||
try {
|
||||
const handle = eventsFactory.createEventHandle(this, this.conn, row);
|
||||
try {
|
||||
await handle.start();
|
||||
} finally {
|
||||
await handle.safeRelease();
|
||||
}
|
||||
} catch (err) {
|
||||
utils.safeDumpErrStack(err);
|
||||
log.error(logHead + err);
|
||||
await utils.sleep(5000 + utils.randRange(500, 1500));
|
||||
}
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user