Apply old PR 243

Closes chrisboulton/php-resque#243
resque · Dec 11, 2018 · 6421998 · 6421998
1 parent dec0d9c
commit 6421998
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/lib/Resque/Worker.php b/lib/Resque/Worker.php
@@ -157,6 +157,18 @@ public function work($interval = Resque::DEFAULT_INTERVAL, $blocking = false)
 				break;
 			}
 
+			// is redis still alive?
+			try {
+			    if (Resque::redis()->ping() === false) {
+			        throw new CredisException('redis ping() failed');
+			    }
+			} catch (CredisException $e) {
+			    $this->logger->log(Psr\Log\LogLevel::ERROR, 'redis went away. trying to reconnect');
+			    Resque::$redis = null;
+			    usleep($interval * 1000000);
+			    continue;
+			}
+
 			// Attempt to find and reserve a job
 			$job = false;
 			if(!$this->paused) {