sfcod / jobqueue

Job/JobContract.php

Doc Comments +1 added lines, -1 removed lines

@@ -89,7 +89,7 @@
      *
      * @param JobResolverInterface $resolver
      * @param QueueInterface $database
-     * @param StdClass|MongoDB\Model\BSONDocument $job
+     * @param Job $job
      */
     public function __construct(JobResolverInterface $resolver, QueueInterface $database, Job $job)
     {

Tests/Job/JobContractTest.php

Doc Comments -1 removed lines

@@ -141,7 +141,6 @@
     /**
      * Mock mongo job contract
      *
-     * @param Job $job
      * @param JobInterface|null $jobInstance
      *
      * @return JobContract

Service/JobQueue.php

Doc Comments +2 added lines, -2 removed lines

@@ -87,7 +87,7 @@ 
     /**
      * Push a new job onto the queue after a delay.
      *
-     * @param \DateInterval|int $delay
+     * @param integer $delay
      * @param string $job
      * @param mixed $data
      * @param string $queue
@@ -103,7 +103,7 @@ 
     /**
      * Push a new job into the queue after a delay if job does not exist.
      *
-     * @param \DateInterval|int $delay
+     * @param integer $delay
      * @param string $job
      * @param mixed $data
      * @param string $queue

Queue/MongoQueue.php

Doc Comments +13 added lines, -13 removed lines

@@ -92,7 +92,7 @@ 
      * @param mixed $data
      * @param string $queue
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function push(string $job, array $data = [], ?string $queue = null)
     {
@@ -104,7 +104,7 @@ 
      *
      * @param string $queue
      *
-     * @return null|JobContractInterface
+     * @return JobContract|null
      */
     public function pop(?string $queue = null): ?JobContractInterface
     {
@@ -141,7 +141,7 @@ 
      * @param string|null $queue
      * @param array $options
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function pushRaw(string $payload, ?string $queue = null, array $options = [])
     {
@@ -151,12 +151,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)
     {
@@ -166,11 +166,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 @@ 
      * Release a reserved job back onto the queue.
      *
      * @param JobContractInterface $job
-     * @param DateInterval|int $delay
+     * @param integer $delay
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function release(JobContractInterface $job, $delay)
     {
@@ -203,7 +203,7 @@ 
      *
      * @param $id
      *
-     * @return null|JobContractInterface
+     * @return null|JobContract
      */
     public function getJobById($id): ?JobContractInterface
     {
@@ -318,7 +318,7 @@ 
      * @param string $payload
      * @param int $attempts
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     protected function pushToDatabase($delay, $queue, $payload, $attempts = 0)
     {
@@ -330,7 +330,7 @@ 
     /**
      * Get the "available at" UNIX timestamp.
      *
-     * @param DateInterval|int $delay
+     * @param integer $delay
      *
      * @return int
      */
@@ -358,7 +358,7 @@ 
      *
      * @param string|null $queue
      *
-     * @return null|JobContractInterface
+     * @return JobContract|null
      */
     protected function getNextAvailableJob($queue)
     {

Command/RetryCommand.php

Unused Use Statements -1 removed lines

@@ -2,7 +2,6 @@
 
 namespace SfCod\QueueBundle\Command;
 
-use SfCod\QueueBundle\Base\MongoDriverInterface;
 use SfCod\QueueBundle\Entity\Job;
 use SfCod\QueueBundle\Failer\FailedJobProviderInterface;
 use SfCod\QueueBundle\Service\JobQueue;