pass pollInterval to paranaoidChecking of pg-listen

darky · Oct 15, 2024 · cf4f7f4 · cf4f7f4
1 parent b2650f8
commit cf4f7f4
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/src/notifier.ts b/src/notifier.ts
@@ -7,10 +7,13 @@ export class Notifier implements StartStop {
 
   constructor(options: Options, private fsm: FSM) {
     import('pg-listen').then(({ default: createSubscriber }) => {
-      this.notifier = createSubscriber({
-        application_name: 'pg_trx_outbox_pubsub',
-        ...options.pgOptions,
-      })
+      this.notifier = createSubscriber(
+        {
+          application_name: 'pg_trx_outbox_pubsub',
+          ...options.pgOptions,
+        },
+        { paranoidChecking: options.outboxOptions?.pollInterval ?? 30_000 }
+      )
       this.notifier.events.on('error', err => options.outboxOptions?.onError?.(err))
     })
   }