This commit is contained in:
aozhiwei 2023-07-11 19:16:44 +08:00
parent 7da42fc7c8
commit 89fc7388a5

View File

@ -219,9 +219,6 @@ 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);
@ -237,6 +234,10 @@ class DbEventProcess extends BaseService {
await utils.sleep(5000 + utils.randRange(500, 1500));
}
}
const idx = BigInt(row['idx']);
if (idx > this.lastIdx) {
this.lastIdx = idx;
}
return true;
}