diff --git a/listener/src/index.ts b/listener/src/index.ts index 3ef63c5..54e9e6b 100644 --- a/listener/src/index.ts +++ b/listener/src/index.ts @@ -185,7 +185,7 @@ async function main() { healthMonitor.start(); } - const subscriber = new EventSubscriber(config); + const subscriber = new EventSubscriber(config, deduplicationService); await subscriber.start(); const shutdown = async () => {