TreeHouse\Queue\Processor\Retry\DeprioritizeStrategy

Complexity

Total Complexity

3

Size/Duplication

Total Lines	32
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	retry()	0	13	2

<?php

namespace TreeHouse\Queue\Processor\Retry;

use TreeHouse\Queue\Amqp\EnvelopeInterface;
use TreeHouse\Queue\Message\Publisher\MessagePublisherInterface;

/**
 * Retries the message, but with the priority decreasing with every attempt.
 */
class DeprioritizeStrategy extends AbstractStrategy
{
    /**
     * @var MessagePublisherInterface
     */
    protected $publisher;

    /**
     * @param MessagePublisherInterface $publisher
     */
    public function __construct(MessagePublisherInterface $publisher)
    {
        $this->publisher = $publisher;
    }

    /**
     * @inheritdoc
     */
    public function retry(EnvelopeInterface $envelope, $attempt, \Exception $exception = null)
    {
        // decrease priority with every attempt
        $priority = $envelope->getPriority();
        if ($priority > 0) {
            --$priority;
        }

        $message = $this->createRetryMessage($envelope, $attempt, $exception);
        $message->setPriority($priority);

        return $this->publisher->publish($message);
    }
}