maintenance 1.0.1

Exceptions/ResqueJobPerformException.php

@@ -4,6 +4,10 @@
 
 use spiritdead\resque\exceptions\base\ResqueException;
 
+/**
+ * Class ResqueJobPerformException
+ * @package spiritdead\resque\exceptions
+ */
 class ResqueJobPerformException extends ResqueException
 {
 

components/workers/ResqueWorker.php

@@ -11,6 +11,10 @@
 use spiritdead\resque\exceptions\base\ResqueException;
 use spiritdead\resque\exceptions\ResqueJobForceExitException;
 
+/**
+ * Class ResqueWorker
+ * @package spiritdead\resque\components\workers
+ */
 class ResqueWorker extends ResqueWorkerBase implements ResqueWorkerInterface
 {
     /**
@@ -132,6 +136,15 @@ public function perform(ResqueJobBase $job)
         $this->logger->log(LogLevel::NOTICE, '{job} has finished', ['job' => $job]);
     }
 
+    /**
+     * Perform necessary actions to start a worker.
+     */
+    public function startup()
+    {
+        $this->pruneDeadWorkers();
+        $this->registerWorker();
+    }
+
     /**
      * Given a worker ID, find it and return an instantiated worker class for it.
      *

components/workers/base/ResqueWorkerBase.php

@@ -155,9 +155,7 @@ public function queues($fetch = true)
     protected function startup()
     {
         $this->registerSigHandlers();
-        $this->pruneDeadWorkers();
         $this->resqueInstance->events->trigger('beforeFirstFork', $this);
-        $this->registerWorker();
     }
 
     /**

components/workers/base/ResqueWorkerInterface.php

@@ -8,6 +8,9 @@
  * Interface ResqueWorkerInterface
  * @package spiritdead\resque\components\workers\base
  */
+abstract class a {
+
+}
 interface ResqueWorkerInterface
 {
     public function work($interval = ResqueWorkerBase::DEFAULT_INTERVAL, $blocking = false);
@@ -31,4 +34,7 @@ public function doneWorking();
     public function getWorking();
 
     public function pruneDeadWorkers();
+
+    public function startup();
+
 }

controllers/ResqueJobFactory.php

@@ -5,6 +5,10 @@
 use spiritdead\resque\components\jobs\ResqueJobInterface;
 use spiritdead\resque\exceptions\base\ResqueException;
 
+/**
+ * Class ResqueJobFactory
+ * @package spiritdead\resque\controllers
+ */
 class ResqueJobFactory
 {
     /**

controllers/ResqueRedis.php

@@ -250,11 +250,18 @@ public function __call($name, $args)
         }
     }
 
+    /**
+     * @return string
+     */
     public function getPrefix()
     {
         return $this->defaultNamespace;
     }
 
+    /**
+     * @param $string
+     * @return string
+     */
     public function removePrefix($string)
     {
         $prefix = $this->defaultNamespace;

controllers/base/ResqueJobFactoryInterface.php

@@ -1,8 +1,12 @@
 <?php
 namespace spiritdead\resque\controllers\base;
 
-use spiritdead\resque\jobs\base\ResqueJobInterface;
+use spiritdead\resque\components\jobs\ResqueJobInterface;
 
+/**
+ * Interface ResqueJobFactoryInterface
+ * @package spiritdead\resque\controllers\base
+ */
 interface ResqueJobFactoryInterface
 {
     /**

helpers/ResqueLog.php

@@ -11,10 +11,21 @@
  */
 class ResqueLog extends AbstractLogger
 {
+    /**
+     * @var bool
+     */
     public $verbose;
 
+    /**
+     * @var bool
+     */
     public $debug;
 
+    /**
+     * ResqueLog constructor.
+     * @param bool $verbose
+     * @param bool $debug
+     */
     public function __construct($verbose = false, $debug = false)
     {
         $this->verbose = $verbose;

models/ResqueBackend.php

@@ -2,6 +2,10 @@
 
 namespace spiritdead\resque\models;
 
+/**
+ * Class ResqueBackend
+ * @package spiritdead\resque\models
+ */
 class ResqueBackend
 {
     /**
@@ -37,7 +41,7 @@ class ResqueBackend
     /**
      * ResqueBackend constructor.
      * @param string $server
-     * @param int $port
+     * @param string $port
      * @param int $database
      */
     public function __construct(
@@ -50,6 +54,9 @@ public function __construct(
         $this->database = $database;
     }
 
+    /**
+     * @return string
+     */
     public function __toString()
     {
         return sprintf('%s:%s', $this->server, $this->port);

plugins/schedule/ResqueScheduler.php

@@ -58,7 +58,7 @@ public function enqueueAt($at, $queue, $class, $args = [])
     /**
      * Directly append an item to the delayed queue schedule.
      *
-     * @param DateTime|int $timestamp Timestamp job is scheduled to be run at.
+     * @param \DateTime|int $timestamp Timestamp job is scheduled to be run at.
      * @param array $item Hash of item to be pushed to schedule.
      */
     public function delayedPush($timestamp, $item)
@@ -147,6 +147,7 @@ public function removeDelayedJobFromTimestamp($timestamp, $queue, $class, $args)
      * @param string $queue Name of the queue the job will be placed on.
      * @param string $class Name of the job class.
      * @param array $args Array of job arguments.
+     * @return array
      */
     private function jobToHash($queue, $class, $args)
     {
@@ -206,7 +207,7 @@ private function getTimestamp($timestamp)
      * that any jobs scheduled for the past when the worker wasn't running are
      * also queued up.
      *
-     * @param \DateTime|int $timestamp Instance of DateTime or UNIX timestamp.
+     * @param \DateTime|int $at Instance of DateTime or UNIX timestamp.
      *                                Defaults to now.
      * @return int|false UNIX timestamp, or false if nothing to run.
      */
@@ -261,7 +262,6 @@ private function validateJob($class, $queue)
                 throw new ResqueException('Jobs must be put in a queue.');
             }
         }
-
         return true;
     }
 }

components/workers/ResqueWorkerScheduler.php → plugins/schedule/workers/ResqueWorkerScheduler.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace spiritdead\resque\components\workers;
+namespace spiritdead\resque\plugins\schedule\workers;
 
 use Psr\Log\LogLevel;
 use spiritdead\resque\components\jobs\base\ResqueJobBase;
@@ -170,12 +170,11 @@ public function enqueueDelayedItemsForTimestamp($timestamp)
     /**
      * Perform necessary actions to start a worker.
      */
-    protected function startup()
+    public function startup()
     {
-        $this->registerSigHandlers();
         $this->pruneDeadWorkers();
-        $this->resqueInstance->events->trigger('beforeFirstFork', $this);
         $this->registerWorker();
+        parent::startup();
     }
 
     /**