From df46bea2441d644f0adeaf4080e9bc97980e94db Mon Sep 17 00:00:00 2001 From: OMPRAKASH MISHRA Date: Wed, 25 Dec 2024 13:24:37 -0800 Subject: [PATCH] Revert "fix: add wait on first connect to true for pod health check not to report connection error restarts" This reverts commit d0e8184d09b6002b5b0403abe7559f261ee43d27. --- webeoc/src/publishers/actions-taken-publisher.service.ts | 1 - webeoc/src/subscribers/actions-taken-subscriber.service.ts | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/webeoc/src/publishers/actions-taken-publisher.service.ts b/webeoc/src/publishers/actions-taken-publisher.service.ts index cfdb751da..863bf9b82 100644 --- a/webeoc/src/publishers/actions-taken-publisher.service.ts +++ b/webeoc/src/publishers/actions-taken-publisher.service.ts @@ -17,7 +17,6 @@ export class ActionsTakenPublisherService { private async initializeNATS() { const nc = await connect({ servers: [process.env.NATS_HOST], - waitOnFirstConnect: true, }); this.jsClient = nc.jetstream(); } diff --git a/webeoc/src/subscribers/actions-taken-subscriber.service.ts b/webeoc/src/subscribers/actions-taken-subscriber.service.ts index d80215384..6d990b872 100644 --- a/webeoc/src/subscribers/actions-taken-subscriber.service.ts +++ b/webeoc/src/subscribers/actions-taken-subscriber.service.ts @@ -19,7 +19,7 @@ export class ActionsTakenSubscriberService implements OnModuleInit { async onModuleInit() { try { - this.natsConnection = await connect({ servers: process.env.NATS_HOST, waitOnFirstConnect: true }); + this.natsConnection = await connect({ servers: process.env.NATS_HOST }); this.jsm = await this.natsConnection.jetstreamManager(); await this.setupStream(); await this.subscribeToTopics();