fix: add wait on first connect to avoid pod restarts due to connectio…

…n failures to nats
bcgov · Dec 25, 2024 · 5d019e2 · 5d019e2
1 parent ec72a52
commit 5d019e2
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 2 deletions.
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/publishers/complaints-publisher.service.ts b/webeoc/src/publishers/complaints-publisher.service.ts
@@ -16,6 +16,7 @@ export class ComplaintsPublisherService {
   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();

diff --git a/webeoc/src/subscribers/complaints-subscriber.service.ts b/webeoc/src/subscribers/complaints-subscriber.service.ts
@@ -19,7 +19,7 @@ export class ComplaintsSubscriberService 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();