File Manager

X7ROOT File Manager

Current Path: /home/prisjneg/public_html/vendor/laravel/framework/src/Illuminate/Events

home / prisjneg / public_html / vendor / laravel / framework / src / Illuminate / Events /

📁 ..
📄 CallQueuedListener.php(3.79 KB)
📄 Dispatcher.php(21.74 KB)
📄 EventServiceProvider.php(761 B)
📄 InvokeQueuedClosure.php(831 B)
📄 LICENSE.md(1.05 KB)
📄 NullDispatcher.php(3.04 KB)
📄 QueuedClosure.php(2.64 KB)
📄 composer.json(1.01 KB)
📄 functions.php(362 B)

Editing: QueuedClosure.php

<?php

namespace Illuminate\Events;

use Closure;
use Laravel\SerializableClosure\SerializableClosure;

class QueuedClosure
{
    /**
     * The underlying Closure.
     *
     * @var \Closure
     */
    public $closure;

/**
     * The name of the connection the job should be sent to.
     *
     * @var string|null
     */
    public $connection;

/**
     * The name of the queue the job should be sent to.
     *
     * @var string|null
     */
    public $queue;

/**
     * The number of seconds before the job should be made available.
     *
     * @var \DateTimeInterface|\DateInterval|int|null
     */
    public $delay;

/**
     * All of the "catch" callbacks for the queued closure.
     *
     * @var array
     */
    public $catchCallbacks = [];

/**
     * Create a new queued closure event listener resolver.
     *
     * @param  \Closure  $closure
     * @return void
     */
    public function __construct(Closure $closure)
    {
        $this->closure = $closure;
    }

/**
     * Set the desired connection for the job.
     *
     * @param  string|null  $connection
     * @return $this
     */
    public function onConnection($connection)
    {
        $this->connection = $connection;

return $this;
    }

/**
     * Set the desired queue for the job.
     *
     * @param  string|null  $queue
     * @return $this
     */
    public function onQueue($queue)
    {
        $this->queue = $queue;

return $this;
    }

/**
     * Set the desired delay in seconds for the job.
     *
     * @param  \DateTimeInterface|\DateInterval|int|null  $delay
     * @return $this
     */
    public function delay($delay)
    {
        $this->delay = $delay;

return $this;
    }

/**
     * Specify a callback that should be invoked if the queued listener job fails.
     *
     * @param  \Closure  $closure
     * @return $this
     */
    public function catch(Closure $closure)
    {
        $this->catchCallbacks[] = $closure;

return $this;
    }

/**
     * Resolve the actual event listener callback.
     *
     * @return \Closure
     */
    public function resolve()
    {
        return function (...$arguments) {
            dispatch(new CallQueuedListener(InvokeQueuedClosure::class, 'handle', [
                'closure' => new SerializableClosure($this->closure),
                'arguments' => $arguments,
                'catch' => collect($this->catchCallbacks)->map(function ($callback) {
                    return new SerializableClosure($callback);
                })->all(),
            ]))->onConnection($this->connection)->onQueue($this->queue)->delay($this->delay);
        };
    }
}

X7ROOT File Manager

Editing: QueuedClosure.php

Upload File

Create Folder