Admin Control Panel v2.0

✎ Editing: IronJob.php ← Back

<?php namespace Illuminate\Queue\Jobs;

use Illuminate\Queue\IronQueue;
use Illuminate\Container\Container;

class IronJob extends Job {

/**
	 * The Iron queue instance.
	 *
	 * @var \Illuminate\Queue\IronQueue
	 */
	protected $iron;

/**
	 * The IronMQ message instance.
	 *
	 * @var object
	 */
	protected $job;

/**
	 * Indicates if the message was a push message.
	 *
	 * @var bool
	 */
	protected $pushed = false;

/**
	 * Create a new job instance.
	 *
	 * @param  \Illuminate\Container\Container  $container
	 * @param  \Illuminate\Queue\IronQueue  $iron
	 * @param  object  $job
	 * @param  bool    $pushed
	 * @return void
	 */
	public function __construct(Container $container,
                                IronQueue $iron,
                                $job,
                                $pushed = false)
	{
		$this->job = $job;
		$this->iron = $iron;
		$this->pushed = $pushed;
		$this->container = $container;
	}

/**
	 * Fire the job.
	 *
	 * @return void
	 */
	public function fire()
	{
		$this->resolveAndFire(json_decode($this->getRawBody(), true));
	}

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

/**
	 * Delete the job from the queue.
	 *
	 * @return void
	 */
	public function delete()
	{
		parent::delete();

if (isset($this->job->pushed)) return;

$this->iron->deleteMessage($this->getQueue(), $this->job->id);
	}

/**
	 * Release the job back into the queue.
	 *
	 * @param  int   $delay
	 * @return void
	 */
	public function release($delay = 0)
	{
		if ( ! $this->pushed) $this->delete();

$this->recreateJob($delay);
	}

/**
	 * Release a pushed job back onto the queue.
	 *
	 * @param  int  $delay
	 * @return void
	 */
	protected function recreateJob($delay)
	{
		$payload = json_decode($this->job->body, true);

array_set($payload, 'attempts', array_get($payload, 'attempts', 1) + 1);

$this->iron->recreate(json_encode($payload), $this->getQueue(), $delay);
	}

/**
	 * Get the number of times the job has been attempted.
	 *
	 * @return int
	 */
	public function attempts()
	{
		return array_get(json_decode($this->job->body, true), 'attempts', 1);
	}

/**
	 * Get the job identifier.
	 *
	 * @return string
	 */
	public function getJobId()
	{
		return $this->job->id;
	}

/**
	 * Get the IoC container instance.
	 *
	 * @return \Illuminate\Container\Container
	 */
	public function getContainer()
	{
		return $this->container;
	}

/**
	 * Get the underlying Iron queue instance.
	 *
	 * @return \Illuminate\Queue\IronQueue
	 */
	public function getIron()
	{
		return $this->iron;
	}

/**
	 * Get the underlying IronMQ job.
	 *
	 * @return array
	 */
	public function getIronJob()
	{
		return $this->job;
	}

/**
	 * Get the name of the queue the job belongs to.
	 *
	 * @return string
	 */
	public function getQueue()
	{
		return array_get(json_decode($this->job->body, true), 'queue');
	}

}

Cancel