From 2d5f22e0e810ec220d41e25cc9b47bbf57223850 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=B8ren=20Rasmussen?= Date: Fri, 29 Jul 2022 01:04:25 +0200 Subject: [PATCH] Set NATS ACK wait to 1 second --- cmd/fermentord/loop.go | 2 +- internal/dwingest/nats.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/fermentord/loop.go b/cmd/fermentord/loop.go index 4f1e625..96c2d25 100644 --- a/cmd/fermentord/loop.go +++ b/cmd/fermentord/loop.go @@ -107,7 +107,7 @@ func mainLoop(ctx context.Context, wg *sync.WaitGroup, js nats.JetStream, config } // Publish to NATS - _, err = js.Publish(config.NATS.Subject.Event, b) + _, err = js.Publish(config.NATS.Subject.Event, b, nats.AckWait(1*time.Second)) if err != nil { hub.CaptureException(err) log.Print(err) diff --git a/internal/dwingest/nats.go b/internal/dwingest/nats.go index b6cf851..5c126ac 100644 --- a/internal/dwingest/nats.go +++ b/internal/dwingest/nats.go @@ -92,7 +92,7 @@ func publish(subject string, js nats.JetStream, hub *sentry.Hub, reading any) er return err } - _, err = js.Publish(subject, b) + _, err = js.Publish(subject, b, nats.AckWait(1*time.Second)) if err != nil { hub.CaptureException(err) log.Print(err)