Resque\FailureHandler

Complexity

Total Complexity

5

Size/Duplication

Total Lines	59
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getBackend()	0	7	2
A	setBackend()	0	3	1
A	createFromError()	0	4	1
A	create()	0	4	1

<?php

namespace Resque;

use \Resque\Worker\ResqueWorker;
use \Exception as CoreException;
use \Error;

/**
 * Failed Resque job.
 *
 * @package		Resque/FailureHandler
 * @author		Chris Boulton <chris@bigcommerce.com>
 * @license		http://www.opensource.org/licenses/mit-license.php
 */
class FailureHandler
{
	/**
	 * @var string Class name representing the backend to pass failed jobs off to.
	 */
	private static $backend;

	/**
	 * Create a new failed job on the backend.
	 *
	 * @param object $payload        The contents of the job that has just failed.
	 * @param \Exception $exception  The exception generated when the job failed to run.
	 * @param \Resque\Worker\ResqueWorker $worker Instance of Resque\Worker\ResqueWorker that was running this job when it failed.
	 * @param string $queue          The name of the queue that this job was fetched from.
	 */
	public static function create($payload, CoreException $exception, ResqueWorker $worker, $queue)
	{
		$backend = self::getBackend();
		new $backend($payload, $exception, $worker, $queue);
	}

	/**
	 * Create a new failed job on the backend from PHP 7 errors.
	 *
	 * @param object $payload        The contents of the job that has just failed.
	 * @param \Error $exception  The PHP 7 error generated when the job failed to run.
	 * @param \Resque\Worker\ResqueWorker $worker Instance of Resque\Worker\ResqueWorker that was running this job when it failed.
	 * @param string $queue          The name of the queue that this job was fetched from.
	 */
	public static function createFromError($payload, Error $exception, ResqueWorker $worker, $queue)
	{
		$backend = self::getBackend();
		new $backend($payload, $exception, $worker, $queue);
	}

	/**
	 * Return an instance of the backend for saving job failures.
	 *
	 * @return object Instance of backend object.
	 */
	public static function getBackend()
	{
		if (self::$backend === null) {

The condition self::backend === null is always false.

			self::$backend = 'Resque\Failure\RedisFailure';
		}

		return self::$backend;

The expression return self::backend returns the type string which is incompatible with the documented return type object.

	}

	/**
	 * Set the backend to use for raised job failures. The supplied backend
	 * should be the name of a class to be instantiated when a job fails.
	 * It is your responsibility to have the backend class loaded (or autoloaded)
	 *
	 * @param string $backend The class name of the backend to pipe failures to.
	 */
	public static function setBackend($backend)
	{
		self::$backend = $backend;
	}
}