From d82546500beb9bd83cc5689fc7c3e2b1842e6e49 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Tue, 11 Jul 2023 16:32:17 +0800
Subject: [PATCH] 1

---
 .../web3dbspider/services/dbevent_process.js  | 19 ++++++++++++++-----
 1 file changed, 14 insertions(+), 5 deletions(-)

diff --git a/server/web3dbspider/services/dbevent_process.js b/server/web3dbspider/services/dbevent_process.js
index 29a0bbf..7d641a7 100644
--- a/server/web3dbspider/services/dbevent_process.js
+++ b/server/web3dbspider/services/dbevent_process.js
@@ -214,14 +214,23 @@ class DbEventProcess extends BaseService {
   }
 
   async process(row) {
+    const logHead = this.getInstanceName() + ' process: ';
     if (!this.eventHandle) {
       return false;
     }
-    const handle = eventsFactory.createEventHandle(this, this.conn, row);
-    try {
-      await handle.start();
-    } finally {
-      await handle.safeRelease();
+    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;
   }