resque / php-resque

lib/ResqueScheduler/Worker.php

Indentation +35 added lines, -35 removed lines

@@ -25,19 +25,19 @@ 
 	 */
 	protected $interval = 5;
 
-    /**
-     * @var boolean True if on the next iteration, the worker should shutdown.
-     */
-    private $shutdown = false;
+	/**
+	 * @var boolean True if on the next iteration, the worker should shutdown.
+	 */
+	private $shutdown = false;
 
 	/**
-	* The primary loop for a worker.
-	*
-	* Every $interval (seconds), the scheduled queue will be checked for jobs
-	* that should be pushed to Resque.
-	*
-	* @param int $interval How often to check schedules.
-	*/
+	 * The primary loop for a worker.
+	 *
+	 * Every $interval (seconds), the scheduled queue will be checked for jobs
+	 * that should be pushed to Resque.
+	 *
+	 * @param int $interval How often to check schedules.
+	 */
 	public function work($interval = null)
 	{
 		if ($interval !== null) {
@@ -47,10 +47,10 @@ 
 		$this->updateProcLine('Starting');
 		$this->registerSigHandlers();
 
-        while (true) {
-            if($this->shutdown) {
-                break;
-            }
+		while (true) {
+			if($this->shutdown) {
+				break;
+			}
 			$this->handleDelayedItems();
 			$this->sleep();
 		}
@@ -136,26 +136,26 @@ 
 		}
 	}
 
-    /**
-     * Register signal handlers that a worker should respond to.
-     *
-     * TERM: Shutdown immediately and stop processing jobs.
-     * INT: Shutdown immediately and stop processing jobs.
-     * QUIT: Shutdown after the current job finishes processing.
-     */
-    private function registerSigHandlers()
-    {
-        if(!function_exists('pcntl_signal')) {
-            return;
-        }
+	/**
+	 * Register signal handlers that a worker should respond to.
+	 *
+	 * TERM: Shutdown immediately and stop processing jobs.
+	 * INT: Shutdown immediately and stop processing jobs.
+	 * QUIT: Shutdown after the current job finishes processing.
+	 */
+	private function registerSigHandlers()
+	{
+		if(!function_exists('pcntl_signal')) {
+			return;
+		}
 
-        pcntl_signal(SIGTERM, array($this, 'shutdown'));
-        pcntl_signal(SIGINT, array($this, 'shutdown'));
-        pcntl_signal(SIGQUIT, array($this, 'shutdown'));
-    }
+		pcntl_signal(SIGTERM, array($this, 'shutdown'));
+		pcntl_signal(SIGINT, array($this, 'shutdown'));
+		pcntl_signal(SIGQUIT, array($this, 'shutdown'));
+	}
 
-    public function shutdown()
-    {
-        $this->shutdown = true;
-    }
+	public function shutdown()
+	{
+		$this->shutdown = true;
+	}
 }