TreeHouse\Queue\Processor\Retry\DeprioritizeStrategy::retry()

Complexity

Conditions	2
Paths	2

Size

Total Lines

13

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	2

Importance

Changes

0

<?php
    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);
    }
}