From fdb7eaffc2fd0e7be6a40fc0d9c228c30e9ee9d4 Mon Sep 17 00:00:00 2001
From: marczahnfc <marc.zahn@fincompare.com>
Date: Tue, 29 Oct 2024 16:09:13 +0100
Subject: [PATCH] Add nak delay from config to Jetstream subscriber (#26)

---
 pkg/jetstream/subscriber.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pkg/jetstream/subscriber.go b/pkg/jetstream/subscriber.go
index 75d9741..26dd587 100644
--- a/pkg/jetstream/subscriber.go
+++ b/pkg/jetstream/subscriber.go
@@ -74,6 +74,7 @@ func newSubscriber(nc *nats.Conn, config *SubscriberConfig) (*Subscriber, error)
 		configureConsumer: config.ConfigureConsumer,
 		consumeOptions:    config.ConsumeOptions,
 		ackAsync:          config.AckAsync,
+		nakDelay:          config.NakDelay,
 	}, nil
 }