public function processJobQueue($name)
    {
        // Start timer to measure lifetime
        $this->markStarted();

        // Begin main loop
        do {
            if (class_exists(Subsite::class)) {
                // clear subsite back to default to prevent any subsite changes from leaking to
                // subsequent actions
                Subsite::changeSubsite(0);
            }

            $job = $this->getNextPendingJob($name);
            if ($job) {
                $success = $this->runJob($job->ID);
                if (!$success) {
                    // make sure job is null so it doesn't continue the current
                    // processing loop. Next queue executor can pick up where
                    // things left off
                    $job = null;
                }
            }
        } while ($job);
    }
public function processJobQueue($name)
    {
        // Start timer to measure lifetime
        $this->markStarted();

        // Begin main loop
        do {
            if (class_exists(Subsite::class)) {
                // clear subsite back to default to prevent any subsite changes from leaking to
                // subsequent actions
                Subsite::changeSubsite(0);
            }

            $job = $this->getNextPendingJob($name);
            if ($job) {
                $success = $this->runJob($job->ID);
                if (!$success) {
                    // make sure job is null so it doesn't continue the current
                    // processing loop. Next queue executor can pick up where
                    // things left off
                    $job = null;
                }
            }
        } while ($job);
    }
public function processJobQueue ( $ name ) { // Start timer to measure lifetime $ this -> markStarted ( ) ; // Begin main loop do { if ( class_exists ( Subsite :: class ) ) { // clear subsite back to default to prevent any subsite changes from leaking to // subsequent actions Subsite :: changeSubsite ( 0 ) ; } $ job = $ this -> getNextPendingJob ( $ name ) ; if ( $ job ) { $ success = $ this -> runJob ( $ job -> ID ) ; if ( ! $ success ) { // make sure job is null so it doesn't continue the current // processing loop. Next queue executor can pick up where // things left off $ job = null ; } } } while ( $ job ) ; }
Process all jobs from a given queue

@param string $name The job queue to completely process
Process all jobs from a given queue