sfcod / jobqueue

Queue/MongoQueue.php

Doc Comments +13 added lines, -13 removed lines

@@ -94,7 +94,7 @@ 
      * @param mixed $data
      * @param string|null $queue
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function push(string $job, array $data = [], ?string $queue = null)
     {
@@ -106,7 +106,7 @@ 
      *
      * @param string|null $queue
      *
-     * @return JobContractInterface|null
+     * @return JobContract|null
      */
     public function pop(?string $queue = null): ?JobContractInterface
     {
@@ -143,7 +143,7 @@ 
      * @param string|null $queue
      * @param array $options
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function pushRaw(string $payload, ?string $queue = null, array $options = [])
     {
@@ -153,12 +153,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|null $queue
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     public function later($delay, string $job, array $data = [], ?string $queue = null)
     {
@@ -168,11 +168,11 @@ 
     /**
      * Push an array of jobs onto the queue.
      *
-     * @param array $jobs
+     * @param string[] $jobs
      * @param mixed $data
      * @param string|null $queue
      *
-     * @return mixed
+     * @return \MongoDB\InsertManyResult
      */
     public function bulk(array $jobs, array $data = [], ?string $queue = null)
     {
@@ -191,9 +191,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)
     {
@@ -206,7 +206,7 @@ 
      * @param string $queue
      * @param string $id
      *
-     * @return JobContractInterface|null
+     * @return null|JobContract
      */
     public function getJobById(string $queue, string $id): ?JobContractInterface
     {
@@ -321,7 +321,7 @@ 
      * @param string $payload
      * @param int $attempts
      *
-     * @return mixed
+     * @return \MongoDB\InsertOneResult
      */
     protected function pushToDatabase($delay, $queue, $payload, $attempts = 0)
     {
@@ -333,7 +333,7 @@ 
     /**
      * Get the "available at" UNIX timestamp.
      *
-     * @param DateInterval|int $delay
+     * @param integer $delay
      *
      * @return int
      */
@@ -361,7 +361,7 @@ 
      *
      * @param string|null $queue
      *
-     * @return JobContractInterface|null
+     * @return JobContract|null
      */
     protected function getNextAvailableJob($queue)
     {

Queue/RedisQueue.php

Doc Comments +3 added lines, -3 removed lines

@@ -154,7 +154,7 @@ 
      *
      * @param string|null $queue
      *
-     * @return JobContractInterface|null
+     * @return null|JobContract
      */
     public function pop(?string $queue = null): ?JobContractInterface
     {
@@ -222,7 +222,7 @@ 
      * @param string $queue
      * @param string $id
      *
-     * @return JobContractInterface|null
+     * @return null|JobContract
      */
     public function getJobById(string $queue, string $id): ?JobContractInterface
     {
@@ -312,7 +312,7 @@ 
     /**
      * Get the "available at" UNIX timestamp.
      *
-     * @param DateInterval|int $delay
+     * @param integer $delay
      *
      * @return int
      */