Classes/EventHandler/ProjectionHandleJob.php
public function execute(QueueInterface $queue, Message $message)
    {
        $projection = $this->eventr->getProjection($this->projectionName);
        $aggregateType = $this->eventr->getAggregateType($this->aggregateType);
        $aggregate = $aggregateType->getAggregate($this->aggregateId);
        $projection->handle($aggregate, $this->event);
        return true;
    }
public function execute(QueueInterface $queue, Message $message)
    {
        $projection = $this->eventr->getProjection($this->projectionName);
        $aggregateType = $this->eventr->getAggregateType($this->aggregateType);
        $aggregate = $aggregateType->getAggregate($this->aggregateId);
        $projection->handle($aggregate, $this->event);
        return true;
    }
public function execute ( QueueInterface $ queue , Message $ message ) { $ projection = $ this -> eventr -> getProjection ( $ this -> projectionName ) ; $ aggregateType = $ this -> eventr -> getAggregateType ( $ this -> aggregateType ) ; $ aggregate = $ aggregateType -> getAggregate ( $ this -> aggregateId ) ; $ projection -> handle ( $ aggregate , $ this -> event ) ; return true ; }
Execute the job
A job should finish itself after successful execution using the queue methods.

@param QueueInterface $queue
@param Message $message The original message
@return boolean TRUE if the job was executed successfully and the message should be finished
Execute the job A job should finish itself after successful execution using the queue methods .