Workana\AsyncJobs\Retry\BinaryExponentialBackoff

Complexity

Total Complexity

4

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	handleRetry()	0	13	3
A	redispatch()	0	8	1

<?php
namespace Workana\AsyncJobs\Retry;

use InvalidArgumentException;
use Bernard\Envelope;
use Workana\AsyncJobs\Job;

/**
 * Binary Exponential Backoff is an algorithm that uses feedback to multiplicatively
 * decrease the rate of some process, in order to gradually find an acceptable rate.
 *
 * @author Carlos Frutos <charly@workana.com>
 */
class BinaryExponentialBackoff extends RetryStrategy
{
    /**
     * {@inheritDoc}
     */
    public function handleRetry(Envelope $envelope, $error)
    {
        $job = $envelope->getMessage();

        if (!($job instanceof Job)) {
            throw new InvalidArgumentException('Envelope message must have a valid job instance');
        }

        if (!$job->areRetriesExhausted()) {
            $job->incrementRetries();
            $this->redispatch($job);
        }
    }

    /**
     * Redispatch job
     *
     * @param Job $job
     *
     * @return void
     */
    private function redispatch(Job $job)
    {
        $delay = pow(2, $job->getRetries());

        $job->withDelay($delay);

        $this->jm->dispatch($job);
    }
}