From f4beebd02f6268cdc712eb010a4028ecc7d1754e Mon Sep 17 00:00:00 2001 From: Mike Mason Date: Wed, 19 Jul 2023 19:12:14 +0000 Subject: [PATCH] manual and explicit acks --- internal/pubsub/nats.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/pubsub/nats.go b/internal/pubsub/nats.go index ed3e2ec..22e4cd0 100644 --- a/internal/pubsub/nats.go +++ b/internal/pubsub/nats.go @@ -51,7 +51,7 @@ func (s *subscriber) SubscribeChanges(ctx context.Context, topic string) (<-chan opts := s.subscriptionOptions - opts = append(opts, nats.Durable(s.durableName(subject))) + opts = append(opts, nats.Durable(s.durableName(subject)), nats.AckExplicit(), nats.ManualAck()) msgCh := make(chan *changeEvent, subscriptionBufferSize)