Ccovey\LaravelRabbitMQ\RabbitMqJob

Complexity

Total Complexity

7

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	attempts()	0	4	1
A	getRawBody()	0	4	1
A	delete()	0	5	1
A	release()	0	14	3

<?php

namespace Ccovey\LaravelRabbitMQ;

use Ccovey\RabbitMQ\Producer\Message;
use Ccovey\RabbitMQ\Producer\Producer;
use Ccovey\RabbitMQ\Producer\ProducerInterface;
use Ccovey\RabbitMQ\QueuedMessage;
use DateTime;
use Illuminate\Contracts\Container\Container;
use Illuminate\Contracts\Queue\Job as JobContract;
use Illuminate\Queue\Jobs\Job;

class RabbitMqJob extends Job implements JobContract
{
    /**
     * @var Container
     */
    protected $container;

    /**
     * @var ProducerInterface
     */
    private $producer;

    /**
     * @var QueuedMessage
     */
    private $message;

    public function __construct(Container $container, ProducerInterface $producer, QueuedMessage $message)
    {
        $this->container = $container;
        $this->producer = $producer;
        $this->message = $message;
    }

    /**
     * Get the number of times the job has been attempted.
     *
     * @return int
     */
    public function attempts()
    {
        return $this->message->attempts ?? 0;
    }

    /**
     * Get the raw body string for the job.
     *
     * @return string
     */
    public function getRawBody()
    {
        $this->message->getRawBody();

The method getRawBody() does not seem to exist on object<Ccovey\RabbitMQ\QueuedMessage>.

    }

    public function delete()
    {
        parent::delete();
        $this->producer->getChannel()->acknowledge($this->message->delivery_tag);
    }

    public function release($delay = 0)
    {
        parent::release($delay);
        $body = $this->message->getBody();

        if ($delay > 0) {
            $body['scheduledAt'] = new DateTime(sprintf('+%s', $delay));
        }

        $body['attempts'] = isset($body['attempts']) ? $body['attempts'] + 1 : 1;
        $message = new Message($body, $this->message->getQueueName());

        $this->producer->publish($message);
    }
}