Admin Control Panel v2.0

✎ Editing: Job.php ← Back

<?php namespace Illuminate\Queue\Jobs;

use DateTime;

abstract class Job {

/**

* The job handler instance.

* @var mixed

protected $instance;

/**

* The IoC container instance.

* @var \Illuminate\Container\Container

protected $container;

/**

* The name of the queue the job belongs to.

* @var string

protected $queue;

/**

* Indicates if the job has been deleted.

* @var bool

protected $deleted = false;

/**

* Fire the job.

* @return void

abstract public function fire();

/**

* Delete the job from the queue.

* @return void

public function delete()

{

$this->deleted = true;

}

/**

* Determine if the job has been deleted.

* @return bool

public function isDeleted()

{

return $this->deleted;

}

/**

* Release the job back into the queue.

* @param  int   $delay

* @return void

abstract public function release($delay = 0);

/**

* Get the number of times the job has been attempted.

* @return int

abstract public function attempts();

/**

* Get the raw body string for the job.

* @return string

abstract public function getRawBody();

/**

* Resolve and fire the job handler method.

* @param  array  $payload

* @return void

protected function resolveAndFire(array $payload)

{

list($class, $method) = $this->parseJob($payload['job']);

$this->instance = $this->resolve($class);

$this->instance->{$method}($this, $payload['data']);

}

/**

* Resolve the given job handler.

* @param  string  $class

* @return mixed

protected function resolve($class)

{

return $this->container->make($class);

}

/**

* Parse the job declaration into class and method.

* @param  string  $job

* @return array

protected function parseJob($job)

{

$segments = explode('@', $job);

return count($segments) > 1 ? $segments : array($segments[0], 'fire');

}

/**

* Determine if job should be auto-deleted.

* @return bool

public function autoDelete()

{

return isset($this->instance->delete);

}

/**

* Calculate the number of seconds with the given delay.

* @param  \DateTime|int  $delay

* @return int

protected function getSeconds($delay)

{

if ($delay instanceof DateTime)

{

return max(0, $delay->getTimestamp() - $this->getTime());

}

return (int) $delay;

}

/**

* Get the current system time.

* @return int

protected function getTime()

{

return time();

}

/**

* Get the name of the queued job class.

* @return string

public function getName()

{

return json_decode($this->getRawBody(), true)['job'];

}

/**

* Get the name of the queue the job belongs to.

* @return string

public function getQueue()

{

return $this->queue;

}

Cancel