protected function queueJob(array $job): bool
    {
        if (!isset($job['status'])) {
            return false;
        }

        if (true === $this->collectJob($job, JobInterface::STATUS_PROCESSING)) {
            $this->processJob($job);
        } elseif (JobInterface::STATUS_POSTPONED === $job['status']) {
            $this->logger->debug('found postponed job ['.$job['_id'].'] to requeue', [
                'category' => get_class($this),
                'pm' => $this->process,
            ]);

            $this->queue[(string) $job['_id']] = $job;
        }

        return true;
    }
protected function queueJob(array $job): bool
    {
        if (!isset($job['status'])) {
            return false;
        }

        if (true === $this->collectJob($job, JobInterface::STATUS_PROCESSING)) {
            $this->processJob($job);
        } elseif (JobInterface::STATUS_POSTPONED === $job['status']) {
            $this->logger->debug('found postponed job ['.$job['_id'].'] to requeue', [
                'category' => get_class($this),
                'pm' => $this->process,
            ]);

            $this->queue[(string) $job['_id']] = $job;
        }

        return true;
    }
protected function queueJob ( array $ job ) : bool { if ( ! isset ( $ job [ 'status' ] ) ) { return false ; } if ( true === $ this -> collectJob ( $ job , JobInterface :: STATUS_PROCESSING ) ) { $ this -> processJob ( $ job ) ; } elseif ( JobInterface :: STATUS_POSTPONED === $ job [ 'status' ] ) { $ this -> logger -> debug ( 'found postponed job [' . $ job [ '_id' ] . '] to requeue' , [ 'category' => get_class ( $ this ) , 'pm' => $ this -> process , ] ) ; $ this -> queue [ ( string ) $ job [ '_id' ] ] = $ job ; } return true ; }
Queue job.
Queue job .