Merge pull request #5 from gyselroth/dev

updates v2.0.5

CHANGELOG.md

@@ -4,6 +4,8 @@
 
 * [CHANGE] Scheduler::cancelJob() not throws Exception\JobNotFound if job was not found
 * [FIX] Fixed driver version (mongodb >= 1.5.0) support for ServerException along ConnectionException to create collection if not propperly setup
+* [FIX] Use collection_name from options instead static queue in getCursor()
+* [CHANGE] Extended phpstan level to 5
 
 
 ## 2.0.4

phpstan.neon

@@ -2,8 +2,6 @@ parameters:
     autoload_directories:
         - %rootDir%/../../../src
         - %rootDir%/../../../tests
-    ignoreErrors:
-        - '#^Class MongoDB\\BSON\\UTCDateTime constructor invoked with 0 parameters, 1 required\.#'
 
 includes:
-    - vendor/phpstan/phpstan/conf/config.level1.neon
+    - vendor/phpstan/phpstan/conf/config.level4.neon

src/Queue.php

@@ -80,7 +80,7 @@ class Queue
     /**
      * Current processing job.
      *
-     * @var array
+     * @var null|array
      */
     protected $current_job;
 
@@ -276,9 +276,9 @@ protected function convertQueue(): self
     /**
      * Retrieve next job.
      *
-     * @param iterable $cursor
+     * @param IteratorIterator $cursor
      */
-    protected function retrieveNextJob(Iterable $cursor)
+    protected function retrieveNextJob(IteratorIterator $cursor)
     {
         try {
             $cursor->next();

src/Scheduler.php

@@ -299,7 +299,7 @@ public function addJobOnce(string $class, $data, array $options = []): ObjectId
             ],
         ];
 
-        $result = $this->db->queue->findOne($filter, [
+        $result = $this->db->{$this->collection_name}->findOne($filter, [
             'typeMap' => self::TYPE_MAP,
         ]);