Skip to content
Snippets Groups Projects
Commit cf85422c authored by Alexey Lunin's avatar Alexey Lunin
Browse files

increase ack wait time to 1 minute

parent cd0ebc8f
No related branches found
No related tags found
No related merge requests found
......@@ -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,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment