concrete/src/Job/QueueableJob.php
public function executeJob()
    {
        // If the job's already running, don't try to restart it
        if ($this->getJobStatus() !== 'RUNNING') {
            $queue = $this->markStarted();

            // Prepare the queue for processing
            $this->start($queue);
        } else {
            $queue = $this->getQueueObject();
        }

        try {
            $batchSize = $this->getJobQueueBatchSize() ?: PHP_INT_MAX;

            // Loop over queue batches
            while (($messages = $queue->receive($batchSize)) && $messages->count() > 0) {
                // Run the batch
                $this->executeBatch($messages, $queue);
            }

            // Mark the queue as finished
            $output = $this->finish($queue);

            // Mark the job as completed
            $result = $this->markCompleted(0, $output);
        } catch (\Exception $e) {
            $result = $this->markCompleted(Job::JOB_ERROR_EXCEPTION_GENERAL, $e->getMessage());
            $result->message = $result->result; // needed for progressive library.
        }

        return $result;
    }
public function executeJob()
    {
        // If the job's already running, don't try to restart it
        if ($this->getJobStatus() !== 'RUNNING') {
            $queue = $this->markStarted();

            // Prepare the queue for processing
            $this->start($queue);
        } else {
            $queue = $this->getQueueObject();
        }

        try {
            $batchSize = $this->getJobQueueBatchSize() ?: PHP_INT_MAX;

            // Loop over queue batches
            while (($messages = $queue->receive($batchSize)) && $messages->count() > 0) {
                // Run the batch
                $this->executeBatch($messages, $queue);
            }

            // Mark the queue as finished
            $output = $this->finish($queue);

            // Mark the job as completed
            $result = $this->markCompleted(0, $output);
        } catch (\Exception $e) {
            $result = $this->markCompleted(Job::JOB_ERROR_EXCEPTION_GENERAL, $e->getMessage());
            $result->message = $result->result; // needed for progressive library.
        }

        return $result;
    }
public function executeJob ( ) { // If the job's already running, don't try to restart it if ( $ this -> getJobStatus ( ) !== 'RUNNING' ) { $ queue = $ this -> markStarted ( ) ; // Prepare the queue for processing $ this -> start ( $ queue ) ; } else { $ queue = $ this -> getQueueObject ( ) ; } try { $ batchSize = $ this -> getJobQueueBatchSize ( ) ? : PHP_INT_MAX ; // Loop over queue batches while ( ( $ messages = $ queue -> receive ( $ batchSize ) ) && $ messages -> count ( ) > 0 ) { // Run the batch $ this -> executeBatch ( $ messages , $ queue ) ; } // Mark the queue as finished $ output = $ this -> finish ( $ queue ) ; // Mark the job as completed $ result = $ this -> markCompleted ( 0 , $ output ) ; } catch ( \ Exception $ e ) { $ result = $ this -> markCompleted ( Job :: JOB_ERROR_EXCEPTION_GENERAL , $ e -> getMessage ( ) ) ; $ result -> message = $ result -> result ; // needed for progressive library. } return $ result ; }
Executejob for queueable jobs actually starts the queue, runs, and ends all in one function. This happens if we run a job in legacy mode.
Executejob for queueable jobs actually starts the queue runs and ends all in one function . This happens if we run a job in legacy mode .