Pause heartbeat detection during reconnection

nats-io · May 17, 2024 · 34dc2a1 · 34dc2a1
1 parent 833574b
commit 34dc2a1
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/jetstream/pull.go b/jetstream/pull.go
@@ -596,6 +596,12 @@ func (s *pullSubscription) Next() (Msg, error) {
 			if errors.Is(err, errConnected) {
 				if !isConnected {
 					isConnected = true
+
+					if hbMonitor != nil {
+						// we are not going to get a heartbeat while reconnecting
+						hbMonitor.Stop()
+					}
+
 					// try fetching consumer info several times to make sure consumer is available after reconnect
 					backoffOpts := backoffOpts{
 						attempts:                10,