sfcod / jobqueue

Command/RunJobCommand.php

Doc Comments -1 removed lines

@@ -25,7 +25,6 @@
     /**
      * RunJobCommand constructor.
      *
-     * @param LoggerInterface $logger
      * @param Worker $worker
      */
     public function __construct(Worker $worker)

Command/RetryCommand.php

Doc Comments -1 removed lines

@@ -35,7 +35,6 @@
      * RetryCommand constructor.
      *
      * @param JobQueue $queue
-     * @param MongoDriverInterface $mongoDriver
      */
     public function __construct(JobQueue $queue, FailedJobProviderInterface $failer)
     {

Job/MongoJobContract.php

Unused Use Statements -1 removed lines

@@ -5,7 +5,6 @@
 use SfCod\QueueBundle\Base\JobInterface;
 use SfCod\QueueBundle\Base\JobResolverInterface;
 use SfCod\QueueBundle\Queue\QueueInterface;
-use stdClass;
 
 /**
  * MongoJob for laravel queue

Service/JobQueue.php

Doc Comments +2 added lines, -4 removed lines

@@ -23,8 +23,6 @@ 
     /**
      * JobQueue constructor.
      *
-     * @param ContainerInterface $container
-     * @param array $connections
      *
      * @internal param array $config
      */
@@ -89,7 +87,7 @@ 
     /**
      * Push a new job onto the queue after a delay.
      *
-     * @param \DateTime|int $delay
+     * @param integer $delay
      * @param string $job
      * @param mixed $data
      * @param string $queue
@@ -105,7 +103,7 @@ 
     /**
      * Push a new job into the queue after a delay if job does not exist.
      *
-     * @param \DateTime|int $delay
+     * @param integer $delay
      * @param string $job
      * @param mixed $data
      * @param string $queue

Worker/Worker.php

Doc Comments -1 removed lines

@@ -70,7 +70,6 @@
     /**
      * Worker constructor.
      *
-     * @param QueueInterface $queue
      * @param JobProcess $process
      * @param FailedJobProviderInterface $failer
      * @param ExceptionHandlerInterface $exceptions

Event/JobFailedEvent.php

Doc Comments -1 removed lines

@@ -43,7 +43,6 @@
      * @param string $connectionName
      * @param JobContractInterface $job
      * @param Exception $exception
-     * @param array $config
      */
     public function __construct(string $connectionName, JobContractInterface $job, Exception $exception)
     {

Event/JobProcessedEvent.php

Doc Comments -1 removed lines

@@ -34,7 +34,6 @@
      *
      * @param string $connectionName
      * @param JobContractInterface $job
-     * @param array $config
      */
     public function __construct(string $connectionName, JobContractInterface $job)
     {

Event/JobProcessingEvent.php

Doc Comments -1 removed lines

@@ -34,7 +34,6 @@
      *
      * @param string $connectionName
      * @param JobContractInterface $job
-     * @param array $config
      */
     public function __construct(string $connectionName, JobContractInterface $job)
     {

Queue/MongoQueue.php

Doc Comments +13 added lines, -13 removed lines

@@ -91,7 +91,7 @@ 
      * @param mixed $data
      * @param string $queue
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function push(string $job, array $data = [], ?string $queue = null)
     {
@@ -103,7 +103,7 @@ 
      *
      * @param string $queue
      *
-     * @return null|JobContractInterface
+     * @return MongoJobContract|null
      */
     public function pop(?string $queue = null): ?JobContractInterface
     {
@@ -140,7 +140,7 @@ 
      * @param string|null $queue
      * @param array $options
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function pushRaw(string $payload, ?string $queue = null, array $options = [])
     {
@@ -150,12 +150,12 @@ 
     /**
      * Push a new job onto the queue after a delay.
      *
-     * @param DateInterval|int $delay
+     * @param integer $delay
      * @param string $job
      * @param array $data
      * @param string $queue
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function later($delay, string $job, array $data = [], ?string $queue = null)
     {
@@ -165,11 +165,11 @@ 
     /**
      * Push an array of jobs onto the queue.
      *
-     * @param array $jobs
+     * @param string[] $jobs
      * @param mixed $data
      * @param string $queue
      *
-     * @return mixed
+     * @return \MongoDB\InsertManyResult
      */
     public function bulk(array $jobs, array $data = [], ?string $queue = null)
     {
@@ -189,9 +189,9 @@ 
      *
      * @param string $queue
      * @param \StdClass $job
-     * @param DateInterval|int $delay
+     * @param integer $delay
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function release(string $queue, $job, $delay)
     {
@@ -203,7 +203,7 @@ 
      *
      * @param $id
      *
-     * @return null|JobContractInterface
+     * @return null|MongoJobContract
      */
     public function getJobById($id): ?JobContractInterface
     {
@@ -320,7 +320,7 @@ 
      * @param string $payload
      * @param int $attempts
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     protected function pushToDatabase($delay, $queue, $payload, $attempts = 0)
     {
@@ -332,7 +332,7 @@ 
     /**
      * Get the "available at" UNIX timestamp.
      *
-     * @param DateInterval|int $delay
+     * @param integer $delay
      *
      * @return int
      */
@@ -360,7 +360,7 @@ 
      *
      * @param string|null $queue
      *
-     * @return null|JobContractInterface
+     * @return MongoJobContract|null
      */
     protected function getNextAvailableJob($queue)
     {