Skip to content

Commit

Permalink
Revert "fix: add wait on first connect to true for pod health check n…
Browse files Browse the repository at this point in the history
…ot to report connection error restarts"

This reverts commit d0e8184.
  • Loading branch information
mishraomp committed Dec 25, 2024
1 parent d0e8184 commit df46bea
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
1 change: 0 additions & 1 deletion webeoc/src/publishers/actions-taken-publisher.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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();
}
Expand Down
2 changes: 1 addition & 1 deletion webeoc/src/subscribers/actions-taken-subscriber.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down

0 comments on commit df46bea

Please sign in to comment.