Merge pull request #1 from pace/remove-consumption-stoppage

Remove consumption stoppage when heartbeat error limit is reached
pace · Aug 27, 2024 · b3db08d · b3db08d
2 parents 93f1717 + c4fae4f
commit b3db08d
Showing 1 changed file with 4 additions and 13 deletions.
diff --git a/connection.go b/connection.go
@@ -158,20 +158,11 @@ func (connection *redisConnection) heartbeat(errChan chan<- error) {
 
 		errorCount++
 
-		if errorCount >= HeartbeatErrorLimit {
-			// reached error limit
-			connection.StopAllConsuming()
-			// Clients reading from errChan need to see this error
-			// This allows them to shut themselves down
-			// Therefore we block adding it to errChan to ensure delivery
-			errChan <- &HeartbeatError{RedisErr: err, Count: errorCount}
-			return
-		} else {
-			select { // try to add error to channel, but don't block
-			case errChan <- &HeartbeatError{RedisErr: err, Count: errorCount}:
-			default:
-			}
+		select { // try to add error to channel, but don't block
+		case errChan <- &HeartbeatError{RedisErr: err, Count: errorCount}:
+		default:
 		}
+
 		// keep trying until we hit the limit
 	}
 }