src/Expose/Console/Command/ProcessQueueCommand.php
protected function processQueue(OutputInterface &$output)
    {
        $manager = $this->getManager();
        $queue = $this->getQueue();
        $path = array();
        $records = $queue->getPending();

        $output->writeln('<info>'.count($records).' records found.</info>');
        if (count($records) == 0) {
            $output->writeln('<error>No records found to process!</error>');
        } else {
            $output->writeln('<info>Processing '.count($records).' records</info>');
        }

        foreach ($records as $record) {
            $manager->runFilters($record['data'], $path);
            $queue->markProcessed($record['_id']);
        }

        $reports = $manager->getReports();
        foreach ($reports as $index => $report) {
            $reports[$index] = $report->toArray(true);
        }
        return $reports;
    }
protected function processQueue(OutputInterface &$output)
    {
        $manager = $this->getManager();
        $queue = $this->getQueue();
        $path = array();
        $records = $queue->getPending();

        $output->writeln('<info>'.count($records).' records found.</info>');
        if (count($records) == 0) {
            $output->writeln('<error>No records found to process!</error>');
        } else {
            $output->writeln('<info>Processing '.count($records).' records</info>');
        }

        foreach ($records as $record) {
            $manager->runFilters($record['data'], $path);
            $queue->markProcessed($record['_id']);
        }

        $reports = $manager->getReports();
        foreach ($reports as $index => $report) {
            $reports[$index] = $report->toArray(true);
        }
        return $reports;
    }
protected function processQueue ( OutputInterface & $ output ) { $ manager = $ this -> getManager ( ) ; $ queue = $ this -> getQueue ( ) ; $ path = array ( ) ; $ records = $ queue -> getPending ( ) ; $ output -> writeln ( '<info>' . count ( $ records ) . ' records found.</info>' ) ; if ( count ( $ records ) == 0 ) { $ output -> writeln ( '<error>No records found to process!</error>' ) ; } else { $ output -> writeln ( '<info>Processing ' . count ( $ records ) . ' records</info>' ) ; } foreach ( $ records as $ record ) { $ manager -> runFilters ( $ record [ 'data' ] , $ path ) ; $ queue -> markProcessed ( $ record [ '_id' ] ) ; } $ reports = $ manager -> getReports ( ) ; foreach ( $ reports as $ index => $ report ) { $ reports [ $ index ] = $ report -> toArray ( true ) ; } return $ reports ; }
Run the queue processing

@param OutputInterface $output Reference to output instance
@return array Updated reports set
Run the queue processing