From 45192b0c1c03b28984525f07ef99926dd960f073 Mon Sep 17 00:00:00 2001 From: Jordan Hotmann Date: Wed, 6 Dec 2023 22:25:13 -0700 Subject: [PATCH] Return from request --- internal/nats/client.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/nats/client.go b/internal/nats/client.go index 2bc6c2b..8b5889f 100644 --- a/internal/nats/client.go +++ b/internal/nats/client.go @@ -89,11 +89,13 @@ func PublishRequest(subject string, message []byte, timeout time.Duration, retri attempts += 1 if attempts > retries { logger.Error("Request retries exceeded", "subject", subject) + return } resp, err := client.Conn.Request(subject, message, timeout) if err == nil { logger.Debug("Request response received", "response", string(resp.Data)) + return } } }