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 } } }