resque / php-resque

lib/Resque.php

Braces +1 added lines, -2 removed lines

@@ -227,8 +227,7 @@
 		);
 		try {
 			Resque_Event::trigger('beforeEnqueue', $hookParams);
-		}
-		catch(Resque_Job_DontCreate $e) {
+		} catch(Resque_Job_DontCreate $e) {
 			return false;
 		}
 

lib/Resque/Worker.php

Braces +6 added lines, -12 removed lines

@@ -182,8 +182,7 @@ 
 					$this->logger->log(Psr\Log\LogLevel::INFO, 'Sleeping for {interval}', array('interval' => $interval));
 					if($this->paused) {
 						$this->updateProcLine('Paused');
-					}
-					else {
+					} else {
 						$this->updateProcLine('Waiting for ' . implode(',', $this->queues));
 					}
 
@@ -225,8 +224,7 @@ 
 					$job->fail(new Resque_Job_DirtyExitException(
 						'Job exited with exit code ' . $exitStatus
 					));
-				}
-				else
+				} else
 				{
 					if (in_array($job->getStatus(), array(Resque_Job_Status::STATUS_WAITING, Resque_Job_Status::STATUS_RUNNING)))
 					{
@@ -253,8 +251,7 @@ 
 		try {
 			Resque_Event::trigger('afterFork', $job);
 			$job->perform();
-		}
-		catch(Exception $e) {
+		} catch(Exception $e) {
 			$this->logger->log(Psr\Log\LogLevel::CRITICAL, '{job} has failed {stack}', array('job' => $job, 'stack' => $e));
 			$job->fail($e);
 			return;
@@ -347,8 +344,7 @@ 
 		$processTitle = 'resque-' . Resque::VERSION . ': ' . $status;
 		if(function_exists('cli_set_process_title') && PHP_OS !== 'Darwin') {
 			cli_set_process_title($processTitle);
-		}
-		else if(function_exists('setproctitle')) {
+		} else if(function_exists('setproctitle')) {
 			setproctitle($processTitle);
 		}
 	}
@@ -431,8 +427,7 @@ 
 			$this->logger->log(Psr\Log\LogLevel::DEBUG, 'Child {child} found, killing.', array('child' => $this->child));
 			posix_kill($this->child, SIGKILL);
 			$this->child = null;
-		}
-		else {
+		} else {
 			$this->logger->log(Psr\Log\LogLevel::INFO, 'Child {child} not found, restarting.', array('child' => $this->child));
 			$this->shutdown();
 		}
@@ -554,8 +549,7 @@ 
 		$job = Resque::redis()->get('worker:' . $this);
 		if(!$job) {
 			return array();
-		}
-		else {
+		} else {
 			return json_decode($job, true);
 		}
 	}

lib/Resque/Redis.php

Braces +5 added lines, -10 removed lines

@@ -115,11 +115,9 @@ 
 		try {
 			if (is_array($server)) {
 				$this->driver = new Credis_Cluster($server);
-			}
-			else if (is_object($client)) {
+			} else if (is_object($client)) {
 				$this->driver = $client;
-			}
-			else {
+			} else {
 				list($host, $port, $dsnDatabase, $user, $password, $options) = self::parseDsn($server);
 				// $user is not used, only $password
 
@@ -144,8 +142,7 @@ 
 			if ($database !== null) {
 				$this->driver->select($database);
 			}
-		}
-		catch(CredisException $e) {
+		} catch(CredisException $e) {
 			throw new Resque_RedisException('Error communicating with Redis: ' . $e->getMessage(), 0, $e);
 		}
 	}
@@ -240,15 +237,13 @@ 
 				foreach ($args[0] AS $i => $v) {
 					$args[0][$i] = self::$defaultNamespace . $v;
 				}
-			}
-			else {
+			} else {
 				$args[0] = self::$defaultNamespace . $args[0];
 			}
 		}
 		try {
 			return $this->driver->__call($name, $args);
-		}
-		catch (CredisException $e) {
+		} catch (CredisException $e) {
 			throw new Resque_RedisException('Error communicating with Redis: ' . $e->getMessage(), 0, $e);
 		}
 	}