This commit is contained in:
aozhiwei 2023-07-11 15:17:52 +08:00
parent be5e3377a1
commit 1262e4cb76
2 changed files with 6 additions and 5 deletions

View File

@ -106,8 +106,9 @@ class DbEventProcess extends BaseService {
this.progInfo['procLastIdx'] = this.lastIdx.toString();
await this.saveLastIdx(this.lastIdx);
} catch (err) {
log.error(logHead + err);
await utils.sleep(5000 + utils.randRange(1000, 3000));
console.log(err.stack);
log.error(logHead + err);
await utils.sleep(5000 + utils.randRange(1000, 3000));
}
}
@ -136,7 +137,7 @@ class DbEventProcess extends BaseService {
}
getInstanceName() {
const instName = this.getNetId() + '.' + this.getContractName() + '.' + this.getEventName();
const instName = this.getNetId() + ' ' + this.getContractName() + '.' + this.getEventName() + ' dbprocess';
return instName;
}

View File

@ -92,8 +92,8 @@ class PullDbEvent extends BaseService {
this.progInfo['lastIdx'] = this.lastIdx.toString();
await this.saveLastIdx(this.lastIdx);
} catch (err) {
log.error(logHead + err);
await utils.sleep(5000 + utils.randRange(1000, 3000));
log.error(logHead + err);
await utils.sleep(5000 + utils.randRange(1000, 3000));
}
}