From 10c1d0b75e1eeb66bd3df9e33c79c1ff2169959d Mon Sep 17 00:00:00 2001
From: Petr Trofimov <pt@onliner.by>
Date: Fri, 23 Aug 2013 12:17:47 +0300
Subject: [PATCH] Resque/Worker: removed reestablishConnection

---
 lib/Resque/Worker.php | 11 -----------
 1 file changed, 11 deletions(-)

diff --git a/lib/Resque/Worker.php b/lib/Resque/Worker.php
index a6c3985..67807bd 100644
--- a/lib/Resque/Worker.php
+++ b/lib/Resque/Worker.php
@@ -350,7 +350,6 @@ class Resque_Worker
 		pcntl_signal(SIGUSR1, array($this, 'killChild'));
 		pcntl_signal(SIGUSR2, array($this, 'pauseProcessing'));
 		pcntl_signal(SIGCONT, array($this, 'unPauseProcessing'));
-		pcntl_signal(SIGPIPE, array($this, 'reestablishRedisConnection'));
 		$this->logger->log(Psr\Log\LogLevel::DEBUG, 'Registered signals');
 	}
 
@@ -373,16 +372,6 @@ class Resque_Worker
 		$this->paused = false;
 	}
 
-	/**
-	 * Signal handler for SIGPIPE, in the event the redis connection has gone away.
-	 * Attempts to reconnect to redis, or raises an Exception.
-	 */
-	public function reestablishRedisConnection()
-	{
-		$this->logger->log(Psr\Log\LogLevel::NOTICE, 'SIGPIPE received; attempting to reconnect');
-		Resque::redis()->establishConnection();
-	}
-
 	/**
 	 * Schedule a worker for shutdown. Will finish processing the current job
 	 * and when the timeout interval is reached, the worker will shut down.