fix: add wait on first connect to true for pod health check not to re…

…port connection error restarts
bcgov · Dec 25, 2024 · d0e8184 · d0e8184
1 parent 31b73ae
commit d0e8184
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/webeoc/src/publishers/actions-taken-publisher.service.ts b/webeoc/src/publishers/actions-taken-publisher.service.ts
@@ -17,6 +17,7 @@ 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
@@ -19,7 +19,7 @@ export class ActionsTakenSubscriberService implements OnModuleInit {
 
   async onModuleInit() {
     try {
-      this.natsConnection = await connect({ servers: process.env.NATS_HOST });
+      this.natsConnection = await connect({ servers: process.env.NATS_HOST, waitOnFirstConnect: true });
       this.jsm = await this.natsConnection.jetstreamManager();
       await this.setupStream();
       await this.subscribeToTopics();