From 7c29a702a4062b8957748887295820df7222c17d Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Thu, 17 Mar 2022 07:59:03 -0700 Subject: [PATCH] Allow infinite retries for context driven Publish Signed-off-by: Derek Collison --- js.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/js.go b/js.go index db76d1518..d526978b2 100644 --- a/js.go +++ b/js.go @@ -433,7 +433,7 @@ func (js *js) PublishMsg(m *Msg, opts ...PubOpt) (*PubAck, error) { } if err != nil { - for r, ttl := 0, o.ttl; err == ErrNoResponders && r < o.rnum; r++ { + for r, ttl := 0, o.ttl; err == ErrNoResponders && (r < o.rnum || o.rnum < 0); r++ { // To protect against small blips in leadership changes etc, if we get a no responders here retry. if o.ctx != nil { select {