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.