<form method="POST">
    <h3>Editing: CallQueuedHandler.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php

namespace Illuminate\Queue;

use Exception;
use Illuminate\Bus\Batchable;
use Illuminate\Contracts\Bus\Dispatcher;
use Illuminate\Contracts\Cache\Repository as Cache;
use Illuminate\Contracts\Container\Container;
use Illuminate\Contracts\Encryption\Encrypter;
use Illuminate\Contracts\Queue\Job;
use Illuminate\Contracts\Queue\ShouldBeUnique;
use Illuminate\Contracts\Queue\ShouldBeUniqueUntilProcessing;
use Illuminate\Database\Eloquent\ModelNotFoundException;
use Illuminate\Pipeline\Pipeline;
use Illuminate\Support\Str;
use ReflectionClass;
use RuntimeException;

class CallQueuedHandler
{
    /**
     * The bus dispatcher implementation.
     *
     * @var \Illuminate\Contracts\Bus\Dispatcher
     */
    protected $dispatcher;

    /**
     * The container instance.
     *
     * @var \Illuminate\Contracts\Container\Container
     */
    protected $container;

    /**
     * Create a new handler instance.
     *
     * @param  \Illuminate\Contracts\Bus\Dispatcher  $dispatcher
     * @param  \Illuminate\Contracts\Container\Container  $container
     * @return void
     */
    public function __construct(Dispatcher $dispatcher, Container $container)
    {
        $this-&gt;container = $container;
        $this-&gt;dispatcher = $dispatcher;
    }

    /**
     * Handle the queued job.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  array  $data
     * @return void
     */
    public function call(Job $job, array $data)
    {
        try {
            $command = $this-&gt;setJobInstanceIfNecessary(
                $job, $this-&gt;getCommand($data)
            );
        } catch (ModelNotFoundException $e) {
            return $this-&gt;handleModelNotFound($job, $e);
        }

        if ($command instanceof ShouldBeUniqueUntilProcessing) {
            $this-&gt;ensureUniqueJobLockIsReleased($command);
        }

        $this-&gt;dispatchThroughMiddleware($job, $command);

        if (! $job-&gt;isReleased() &amp;&amp; ! $command instanceof ShouldBeUniqueUntilProcessing) {
            $this-&gt;ensureUniqueJobLockIsReleased($command);
        }

        if (! $job-&gt;hasFailed() &amp;&amp; ! $job-&gt;isReleased()) {
            $this-&gt;ensureNextJobInChainIsDispatched($command);
            $this-&gt;ensureSuccessfulBatchJobIsRecorded($command);
        }

        if (! $job-&gt;isDeletedOrReleased()) {
            $job-&gt;delete();
        }
    }

    /**
     * Get the command from the given payload.
     *
     * @param  array  $data
     * @return mixed
     *
     * @throws \RuntimeException
     */
    protected function getCommand(array $data)
    {
        if (Str::startsWith($data['command'], 'O:')) {
            return unserialize($data['command']);
        }

        if ($this-&gt;container-&gt;bound(Encrypter::class)) {
            return unserialize($this-&gt;container[Encrypter::class]-&gt;decrypt($data['command']));
        }

        throw new RuntimeException('Unable to extract job payload.');
    }

    /**
     * Dispatch the given job / command through its specified middleware.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  mixed  $command
     * @return mixed
     */
    protected function dispatchThroughMiddleware(Job $job, $command)
    {
        return (new Pipeline($this-&gt;container))-&gt;send($command)
                -&gt;through(array_merge(method_exists($command, 'middleware') ? $command-&gt;middleware() : [], $command-&gt;middleware ?? []))
                -&gt;then(function ($command) use ($job) {
                    return $this-&gt;dispatcher-&gt;dispatchNow(
                        $command, $this-&gt;resolveHandler($job, $command)
                    );
                });
    }

    /**
     * Resolve the handler for the given command.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  mixed  $command
     * @return mixed
     */
    protected function resolveHandler($job, $command)
    {
        $handler = $this-&gt;dispatcher-&gt;getCommandHandler($command) ?: null;

        if ($handler) {
            $this-&gt;setJobInstanceIfNecessary($job, $handler);
        }

        return $handler;
    }

    /**
     * Set the job instance of the given class if necessary.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  mixed  $instance
     * @return mixed
     */
    protected function setJobInstanceIfNecessary(Job $job, $instance)
    {
        if (in_array(InteractsWithQueue::class, class_uses_recursive($instance))) {
            $instance-&gt;setJob($job);
        }

        return $instance;
    }

    /**
     * Ensure the next job in the chain is dispatched if applicable.
     *
     * @param  mixed  $command
     * @return void
     */
    protected function ensureNextJobInChainIsDispatched($command)
    {
        if (method_exists($command, 'dispatchNextJobInChain')) {
            $command-&gt;dispatchNextJobInChain();
        }
    }

    /**
     * Ensure the batch is notified of the successful job completion.
     *
     * @param  mixed  $command
     * @return void
     */
    protected function ensureSuccessfulBatchJobIsRecorded($command)
    {
        $uses = class_uses_recursive($command);

        if (! in_array(Batchable::class, $uses) ||
            ! in_array(InteractsWithQueue::class, $uses) ||
            is_null($command-&gt;batch())) {
            return;
        }

        $command-&gt;batch()-&gt;recordSuccessfulJob($command-&gt;job-&gt;uuid());
    }

    /**
     * Ensure the lock for a unique job is released.
     *
     * @param  mixed  $command
     * @return void
     */
    protected function ensureUniqueJobLockIsReleased($command)
    {
        if (! $command instanceof ShouldBeUnique) {
            return;
        }

        $uniqueId = method_exists($command, 'uniqueId')
                    ? $command-&gt;uniqueId()
                    : ($command-&gt;uniqueId ?? '');

        $cache = method_exists($command, 'uniqueVia')
                    ? $command-&gt;uniqueVia()
                    : $this-&gt;container-&gt;make(Cache::class);

        $cache-&gt;lock(
            'laravel_unique_job:'.get_class($command).$uniqueId
        )-&gt;forceRelease();
    }

    /**
     * Handle a model not found exception.
     *
     * @param  \Illuminate\Contracts\Queue\Job  $job
     * @param  \Throwable  $e
     * @return void
     */
    protected function handleModelNotFound(Job $job, $e)
    {
        $class = $job-&gt;resolveName();

        try {
            $shouldDelete = (new ReflectionClass($class))
                    -&gt;getDefaultProperties()['deleteWhenMissingModels'] ?? false;
        } catch (Exception $e) {
            $shouldDelete = false;
        }

        if ($shouldDelete) {
            return $job-&gt;delete();
        }

        return $job-&gt;fail($e);
    }

    /**
     * Call the failed method on the job instance.
     *
     * The exception that caused the failure will be passed.
     *
     * @param  array  $data
     * @param  \Throwable|null  $e
     * @param  string  $uuid
     * @return void
     */
    public function failed(array $data, $e, string $uuid)
    {
        $command = $this-&gt;getCommand($data);

        if (! $command instanceof ShouldBeUniqueUntilProcessing) {
            $this-&gt;ensureUniqueJobLockIsReleased($command);
        }

        $this-&gt;ensureFailedBatchJobIsRecorded($uuid, $command, $e);
        $this-&gt;ensureChainCatchCallbacksAreInvoked($uuid, $command, $e);

        if (method_exists($command, 'failed')) {
            $command-&gt;failed($e);
        }
    }

    /**
     * Ensure the batch is notified of the failed job.
     *
     * @param  string  $uuid
     * @param  mixed  $command
     * @param  \Throwable  $e
     * @return void
     */
    protected function ensureFailedBatchJobIsRecorded(string $uuid, $command, $e)
    {
        if (! in_array(Batchable::class, class_uses_recursive($command)) ||
            is_null($command-&gt;batch())) {
            return;
        }

        $command-&gt;batch()-&gt;recordFailedJob($uuid, $e);
    }

    /**
     * Ensure the chained job catch callbacks are invoked.
     *
     * @param  string  $uuid
     * @param  mixed  $command
     * @param  \Throwable  $e
     * @return void
     */
    protected function ensureChainCatchCallbacksAreInvoked(string $uuid, $command, $e)
    {
        if (method_exists($command, 'invokeChainCatchCallbacks')) {
            $command-&gt;invokeChainCatchCallbacks($e);
        }
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>