Make a break if failed to save into neo4j

config.json

@@ -8,7 +8,7 @@
       "group.id": "linker",
       "socket.keepalive.enable": true,
       "enable.auto.commit": true,
-      "queued.max.messages.kbytes": 1000
+      "queued.max.messages.kbytes": 100
     },
     "topics": {
       "topics": ["linker"]

src/neo4j-linker.ts

@@ -53,9 +53,10 @@ export class Linker {
         session.close();
         resolve();
       }).catch((err) => {
-        session.close();
-        throw err;
-        // reject(`Error while saving a connection to neo4j ${JSON.stringify(err)}`);
+        setTimeout(() => {
+          session.close();
+          reject(`Error while saving a connection to neo4j ${JSON.stringify(err)}`);
+        }, 500);
       });
     });