File tree Expand file tree Collapse file tree 1 file changed +0
-11
lines changed Expand file tree Collapse file tree 1 file changed +0
-11
lines changed Original file line number Diff line number Diff line change @@ -350,7 +350,6 @@ private function registerSigHandlers()
350
350
pcntl_signal (SIGUSR1 , array ($ this , 'killChild ' ));
351
351
pcntl_signal (SIGUSR2 , array ($ this , 'pauseProcessing ' ));
352
352
pcntl_signal (SIGCONT , array ($ this , 'unPauseProcessing ' ));
353
- pcntl_signal (SIGPIPE , array ($ this , 'reestablishRedisConnection ' ));
354
353
$ this ->logger ->log (Psr \Log \LogLevel::DEBUG , 'Registered signals ' );
355
354
}
356
355
@@ -373,16 +372,6 @@ public function unPauseProcessing()
373
372
$ this ->paused = false ;
374
373
}
375
374
376
- /**
377
- * Signal handler for SIGPIPE, in the event the redis connection has gone away.
378
- * Attempts to reconnect to redis, or raises an Exception.
379
- */
380
- public function reestablishRedisConnection ()
381
- {
382
- $ this ->logger ->log (Psr \Log \LogLevel::NOTICE , 'SIGPIPE received; attempting to reconnect ' );
383
- Resque::redis ()->establishConnection ();
384
- }
385
-
386
375
/**
387
376
* Schedule a worker for shutdown. Will finish processing the current job
388
377
* and when the timeout interval is reached, the worker will shut down.
You can’t perform that action at this time.
0 commit comments