src/Search/Framework/Collector.php
public function queue()
    {
        $log = $this->getLogger();
        $log->info('Queueing operation started', array('collections' => count($this)));

        $event = new CollectorEvent($this);
        $this->dispatchEvent(SearchEvents::COLLECTOR_PRE_QUEUE, $event);

        $num_queued = 0;
        foreach ($this->_collections as $collection) {
            $num_queued += $this->queueCollection($collection);
        }

        $this->dispatchEvent(SearchEvents::COLLECTOR_POST_QUEUE, $event);

        $log->info('Queueing operation completed', array('queued' => $num_queued));
        return $num_queued;
    }
public function queue()
    {
        $log = $this->getLogger();
        $log->info('Queueing operation started', array('collections' => count($this)));

        $event = new CollectorEvent($this);
        $this->dispatchEvent(SearchEvents::COLLECTOR_PRE_QUEUE, $event);

        $num_queued = 0;
        foreach ($this->_collections as $collection) {
            $num_queued += $this->queueCollection($collection);
        }

        $this->dispatchEvent(SearchEvents::COLLECTOR_POST_QUEUE, $event);

        $log->info('Queueing operation completed', array('queued' => $num_queued));
        return $num_queued;
    }
public function queue ( ) { $ log = $ this -> getLogger ( ) ; $ log -> info ( 'Queueing operation started' , array ( 'collections' => count ( $ this ) ) ) ; $ event = new CollectorEvent ( $ this ) ; $ this -> dispatchEvent ( SearchEvents :: COLLECTOR_PRE_QUEUE , $ event ) ; $ num_queued = 0 ; foreach ( $ this -> _collections as $ collection ) { $ num_queued += $ this -> queueCollection ( $ collection ) ; } $ this -> dispatchEvent ( SearchEvents :: COLLECTOR_POST_QUEUE , $ event ) ; $ log -> info ( 'Queueing operation completed' , array ( 'queued' => $ num_queued ) ) ; return $ num_queued ; }
Queues the items scheduled for indexing for all collections attached to
the collector.

@return int
The number of items sent to the queue.
Queues the items scheduled for indexing for all collections attached to the collector .