diff --git a/libs/nats/src/consumer.nats.service.ts b/libs/nats/src/consumer.nats.service.ts index d1dfbc4eaa9973f9a42953f433415781bc9ebfea..a3aac91e883572f22c7f7579fff7f956bc8a7f85 100644 --- a/libs/nats/src/consumer.nats.service.ts +++ b/libs/nats/src/consumer.nats.service.ts @@ -27,6 +27,7 @@ export class ConsumerService extends NatsBaseService { private registerConsumer = (stream: string) => { const consumerConfig: ConsumerConfig = { max_deliver: 3, + ack_wait: 60 * 1000_000_000, // increase wait time to 1 minute name: this.agentConfig.agentConsumerName, ack_policy: AckPolicy.Explicit, deliver_policy: DeliverPolicy.All,