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;
    }