mpclarkson / resque-bundle

Resque.php

Doc Comments +2 added lines, -2 removed lines

@@ -188,7 +188,7 @@ 
 
     /**
      * @param Job $job
-     * @return mixed
+     * @return integer
      */
     public function removedDelayed(Job $job)
     {
@@ -301,7 +301,7 @@ 
     }
 
     /**
-     * @return mixed
+     * @return integer
      */
     public function getNumberOfDelayedJobs()
     {

Spacing +7 added lines, -7 removed lines

@@ -83,7 +83,7 @@ 
             'port'     => $port,
             'database' => $database,
         ];
-        $host = substr($host, 0, 1) == '/' ? $host : $host . ':' . $port;
+        $host = substr($host, 0, 1) == '/' ? $host : $host.':'.$port;
 
         \Resque::setBackend($host, $database);
     }
@@ -222,7 +222,7 @@ 
      */
     public function getQueues()
     {
-        return \array_map(function ($queue) {
+        return \array_map(function($queue) {
             return new Queue($queue);
         }, \Resque::queues());
     }
@@ -241,7 +241,7 @@ 
      */
     public function getWorkers()
     {
-        return \array_map(function ($worker) {
+        return \array_map(function($worker) {
             return new Worker($worker);
         }, \Resque_Worker::all());
     }
@@ -294,7 +294,7 @@ 
         //TODO: find a more efficient way to do this
         $out = [];
         foreach ($timestamps as $timestamp) {
-            $out[] = [$timestamp, \Resque::redis()->llen('delayed:' . $timestamp)];
+            $out[] = [$timestamp, \Resque::redis()->llen('delayed:'.$timestamp)];
         }
 
         return $out;
@@ -314,7 +314,7 @@ 
      */
     public function getJobsForTimestamp($timestamp)
     {
-        $jobs = \Resque::redis()->lrange('delayed:' . $timestamp, 0, -1);
+        $jobs = \Resque::redis()->lrange('delayed:'.$timestamp, 0, -1);
         $out = [];
         foreach ($jobs as $job) {
             $out[] = json_decode($job, TRUE);
@@ -329,8 +329,8 @@ 
      */
     public function clearQueue($queue)
     {
-        $length = \Resque::redis()->llen('queue:' . $queue);
-        \Resque::redis()->del('queue:' . $queue);
+        $length = \Resque::redis()->llen('queue:'.$queue);
+        \Resque::redis()->del('queue:'.$queue);
 
         return $length;
     }

Command/StartWorkerCommand.php

Spacing +6 added lines, -6 removed lines

@@ -80,7 +80,7 @@ 
         $redisDatabase = $this->getContainer()->getParameter('resque.redis.database');
 
         if ($redisHost != NULL && $redisPort != NULL) {
-            $env['REDIS_BACKEND'] = $redisHost . ':' . $redisPort;
+            $env['REDIS_BACKEND'] = $redisHost.':'.$redisPort;
         }
 
         if (isset($redisDatabase)) {
@@ -88,14 +88,14 @@ 
         }
 
         $opt = '';
-        if (0 !== $m = (int)$input->getOption('memory-limit')) {
+        if (0 !== $m = (int) $input->getOption('memory-limit')) {
             $opt = sprintf('-d memory_limit=%dM', $m);
         }
 
         if (version_compare(PHP_VERSION, '5.4.0') >= 0) {
             $phpExecutable = PHP_BINARY;
         } else {
-            $phpExecutable = PHP_BINDIR . '/php';
+            $phpExecutable = PHP_BINDIR.'/php';
             if (defined('PHP_WINDOWS_VERSION_BUILD')) {
                 $phpExecutable = 'php';
             }
@@ -104,7 +104,7 @@ 
         $workerCommand = strtr('%php% %opt% %dir%/resque', [
             '%php%' => $phpExecutable,
             '%opt%' => $opt,
-            '%dir%' => __DIR__ . '/../bin',
+            '%dir%' => __DIR__.'/../bin',
         ]);
 
         if (!$input->getOption('foreground')) {
@@ -119,7 +119,7 @@ 
         // this is a workaround where we add the vars to the existing environment.
         if (defined('PHP_WINDOWS_VERSION_BUILD')) {
             foreach ($env as $key => $value) {
-                putenv($key . "=" . $value);
+                putenv($key."=".$value);
             }
             $env = NULL;
         }
@@ -132,7 +132,7 @@ 
 
         // if foreground, we redirect output
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Command/ClearQueueCommand.php

Spacing +1 added lines, -1 removed lines

@@ -36,7 +36,7 @@
         $queue = $input->getArgument('queue');
         $count = $resque->clearQueue($queue);
 
-        $output->writeln('Cleared queue ' . $queue . ' - removed ' . $count . ' entries');
+        $output->writeln('Cleared queue '.$queue.' - removed '.$count.' entries');
 
         return 0;
     }

Command/StartScheduledWorkerCommand.php

Spacing +9 added lines, -9 removed lines

@@ -35,7 +35,7 @@ 
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $pidFile = $this->getContainer()->get('kernel')->getCacheDir() . '/resque_scheduledworker.pid';
+        $pidFile = $this->getContainer()->get('kernel')->getCacheDir().'/resque_scheduledworker.pid';
         if (file_exists($pidFile) && !$input->getOption('force')) {
             throw new \Exception('PID file exists - use --force to override');
         }
@@ -47,7 +47,7 @@ 
         $env = [
             'APP_INCLUDE' => $this->getContainer()->getParameter('resque.app_include'),
             'VVERBOSE'    => 1,
-            'RESQUE_PHP'  => $this->getContainer()->getParameter('resque.vendor_dir') . '/chrisboulton/php-resque/lib/Resque.php',
+            'RESQUE_PHP'  => $this->getContainer()->getParameter('resque.vendor_dir').'/chrisboulton/php-resque/lib/Resque.php',
             'INTERVAL'    => $input->getOption('interval'),
         ];
 
@@ -66,7 +66,7 @@ 
         $redisDatabase = $this->getContainer()->getParameter('resque.redis.database');
 
         if ($redisHost != NULL && $redisPort != NULL) {
-            $env['REDIS_BACKEND'] = $redisHost . ':' . $redisPort;
+            $env['REDIS_BACKEND'] = $redisHost.':'.$redisPort;
         }
 
         if (isset($redisDatabase)) {
@@ -76,19 +76,19 @@ 
         if (version_compare(PHP_VERSION, '5.4.0') >= 0) {
             $phpExecutable = PHP_BINARY;
         } else {
-            $phpExecutable = PHP_BINDIR . '/php';
+            $phpExecutable = PHP_BINDIR.'/php';
             if (defined('PHP_WINDOWS_VERSION_BUILD')) {
                 $phpExecutable = 'php';
             }
         }
 
-        $workerCommand = $phpExecutable . ' ' . __DIR__ . '/../bin/resque-scheduler';
+        $workerCommand = $phpExecutable.' '.__DIR__.'/../bin/resque-scheduler';
 
         if (!$input->getOption('foreground')) {
             $logFile = $this->getContainer()->getParameter(
                     'kernel.logs_dir'
-                ) . '/resque-scheduler_' . $this->getContainer()->getParameter('kernel.environment') . '.log';
-            $workerCommand = 'nohup ' . $workerCommand . ' > ' . $logFile . ' 2>&1 & echo $!';
+                ).'/resque-scheduler_'.$this->getContainer()->getParameter('kernel.environment').'.log';
+            $workerCommand = 'nohup '.$workerCommand.' > '.$logFile.' 2>&1 & echo $!';
         }
 
         // In windows: When you pass an environment to CMD it replaces the old environment
@@ -96,7 +96,7 @@ 
         // this is a workaround where we add the vars to the existing environment.
         if (defined('PHP_WINDOWS_VERSION_BUILD')) {
             foreach ($env as $key => $value) {
-                putenv($key . "=" . $value);
+                putenv($key."=".$value);
             }
             $env = NULL;
         }
@@ -106,7 +106,7 @@ 
         $output->writeln(\sprintf('Starting worker <info>%s</info>', $process->getCommandLine()));
 
         if ($input->getOption('foreground')) {
-            $process->run(function ($type, $buffer) use ($output) {
+            $process->run(function($type, $buffer) use ($output) {
                 $output->write($buffer);
             });
         } // else we recompose and display the worker id

Command/StopScheduledWorkerCommand.php

Spacing +2 added lines, -2 removed lines

@@ -29,7 +29,7 @@ 
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $pidFile = $this->getContainer()->get('kernel')->getCacheDir() . '/resque_scheduledworker.pid';
+        $pidFile = $this->getContainer()->get('kernel')->getCacheDir().'/resque_scheduledworker.pid';
 
         if (!file_exists($pidFile)) {
             $output->writeln('No PID file found');
@@ -39,7 +39,7 @@ 
 
         $pid = file_get_contents($pidFile);
 
-        $output->writeln('Killing process ' . $pid);
+        $output->writeln('Killing process '.$pid);
 
         \posix_kill($pid, SIGKILL);
 

DependencyInjection/ResqueExtension.php

Spacing +1 added lines, -1 removed lines

@@ -22,7 +22,7 @@
         $configuration = new Configuration();
         $config = $this->processConfiguration($configuration, $configs);
 
-        $loader = new Loader\XmlFileLoader($container, new FileLocator(__DIR__ . '/../Resources/config'));
+        $loader = new Loader\XmlFileLoader($container, new FileLocator(__DIR__.'/../Resources/config'));
         $loader->load('services.xml');
 
         $container->setParameter('resque.vendor_dir', $config['vendor_dir']);

Queue.php

Spacing +1 added lines, -1 removed lines

@@ -41,7 +41,7 @@
      */
     public function getJobs($start = 0, $stop = -1)
     {
-        $jobs = \Resque::redis()->lrange('queue:' . $this->name, $start, $stop);
+        $jobs = \Resque::redis()->lrange('queue:'.$this->name, $start, $stop);
 
         $result = [];
         foreach ($jobs as $job) {

Worker.php

Spacing +2 added lines, -2 removed lines

@@ -37,7 +37,7 @@ 
      */
     public function getId()
     {
-        return (string)$this->worker;
+        return (string) $this->worker;
     }
 
     /**
@@ -45,7 +45,7 @@ 
      */
     public function getQueues()
     {
-        return \array_map(function ($queue) {
+        return \array_map(function($queue) {
             return new Queue($queue);
         }, $this->worker->queues());
     }