concrete/src/Foundation/Processor/ProcessorQueue.php
public function process()
    {
        $queue = $this->getQueue();
        $tasks = $this->getTasks();
        foreach ($this->target->getItems() as $targetItem) {
            foreach ($tasks as $task) {
                $action = new QueueAction($this, $this->target, $task[1], $targetItem);
                $queue->send(serialize($action));
            }
        }
    }
public function process()
    {
        $queue = $this->getQueue();
        $tasks = $this->getTasks();
        foreach ($this->target->getItems() as $targetItem) {
            foreach ($tasks as $task) {
                $action = new QueueAction($this, $this->target, $task[1], $targetItem);
                $queue->send(serialize($action));
            }
        }
    }
public function process ( ) { $ queue = $ this -> getQueue ( ) ; $ tasks = $ this -> getTasks ( ) ; foreach ( $ this -> target -> getItems ( ) as $ targetItem ) { foreach ( $ tasks as $ task ) { $ action = new QueueAction ( $ this , $ this -> target , $ task [ 1 ] , $ targetItem ) ; $ queue -> send ( serialize ( $ action ) ) ; } } }
Takes the current queue, and fills it based on the currently registered tasks and the
registered processor.
Takes the current queue and fills it based on the currently registered tasks and the registered processor .