Add nak delay from config to Jetstream subscriber (#26)

ThreeDotsLabs · Oct 29, 2024 · fdb7eaf · fdb7eaf
1 parent f21ab4e
commit fdb7eaf
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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
 }