Shippinno\Job\Application\Messaging\RequeueAbandonedJobMessageService::execute()

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function execute(int $abandonedJobMessageId)
    {
        $abandonedJobMessage = $this->abandonedJobMessageStore->abandonedJobMessageOfId($abandonedJobMessageId);
        $queue = $this->context->createQueue($abandonedJobMessage->queue());

The method queue() does not seem to exist on object<Shippinno\Job\Domain\Model\AbandonedJobMessage>.

        $message = $this->context->createMessage($$abandonedJobMessage->message());
        try {
            $this->context->createProducer()->send($queue, $message);
        } catch (QueueException $e) {
//            throw new FailedToEnqueueStoredJobException($e);
        }
    }
}