InteropJob.php

<?php

namespace Illuminate\Queue\Jobs;

use Illuminate\Container\Container;
use Illuminate\Contracts\Queue\Job as JobContract;
use Interop\Queue\PsrConsumer;
use Interop\Queue\PsrContext;
use Interop\Queue\PsrMessage;

class InteropJob extends Job implements JobContract
{
    /**
     * @var PsrContext
     */
    private $psrContext;

    /**
     * @var PsrConsumer
     */
    private $psrConsumer;

    /**
     * @var PsrMessage
     */
    private $psrMessage;

    /**
     * @param Container   $container
     * @param PsrContext  $psrContext
     * @param PsrConsumer $psrConsumer
     * @param PsrMessage  $psrMessage
     * @param string      $connectionName
     */
    public function __construct(Container $container, PsrContext $psrContext, PsrConsumer $psrConsumer, PsrMessage $psrMessage, $connectionName)
    {
        $this->container = $container;
        $this->psrContext = $psrContext;
        $this->psrConsumer = $psrConsumer;
        $this->psrMessage = $psrMessage;
        $this->connectionName = $connectionName;
    }

    /**
     * {@inheritdoc}
     */
    public function delete()
    {
        parent::delete();

        $this->psrConsumer->acknowledge($this->psrMessage);
    }

    /**
     * {@inheritdoc}
     */
    public function release($delay = 0)
    {
        if ($delay) {
            throw new \LogicException('To be implemented');
        }

        $requeueMessage = clone $this->psrMessage;
        $requeueMessage->setProperty('x-attempts', $this->attempts() + 1);

        $this->psrContext->createProducer()->send($this->psrConsumer->getQueue(), $requeueMessage);

        $this->psrConsumer->acknowledge($this->psrMessage);
    }

    /**
     * {@inheritdoc}
     */
    public function getQueue()
    {
        return $this->psrConsumer->getQueue()->getQueueName();
    }

    /**
     * {@inheritdoc}
     */
    public function attempts()
    {
        return $this->psrMessage->getProperty('x-attempts', 1);
    }

    /**
     * {@inheritdoc}
     */
    public function getRawBody()
    {
        return $this->psrMessage->getBody();
    }
}