fix: if destroy lock set destroy lock on start - destroy locks after …

…starting listening
imqueue · May 3, 2022 · b764f1a · b764f1a
1 parent 8af25ae
commit b764f1a
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/PgIpLock.ts b/src/PgIpLock.ts
@@ -112,11 +112,6 @@ export class PgIpLock implements AnyLock {
         await this.createSchema();
         await Promise.all([this.createLock(), this.createDeadlockCheck()]);
 
-        // istanbul ignore if
-        if (DESTROY_LOCK_ON_START) {
-            await destroyLock();
-        }
-
         if (this.notifyHandler) {
             this.options.pgClient.on('notification', this.notifyHandler);
         }
@@ -131,6 +126,11 @@ export class PgIpLock implements AnyLock {
             async () => !this.acquired && this.acquire(),
             this.options.acquireInterval,
         ));
+
+        // istanbul ignore if
+        if (DESTROY_LOCK_ON_START) {
+            await destroyLock();
+        }
     }
 
     /**