FM / Events

/home/techb158/dev.balacoffee.com/vendor/laravel/framework/src/Illuminate/Events/

/home/techb158/dev.balacoffee.com/vendor/laravel/framework/src/Illuminate/Events

Name	Size	Mode	Actions
CallQueuedListener.php	3738	0644	edit dl rm
composer.json	1034	0644	edit dl rm
Dispatcher.php	19131	0644	edit dl rm
EventServiceProvider.php	556	0644	edit dl rm
functions.php	362	0644	edit dl rm
InvokeQueuedClosure.php	831	0644	edit dl rm
LICENSE.md	1075	0644	edit dl rm
NullDispatcher.php	3113	0644	edit dl rm
QueuedClosure.php	2707	0644	edit dl rm

Edit: /home/techb158/dev.balacoffee.com/vendor/laravel/framework/src/Illuminate/Events/QueuedClosure.php (2707B)

<?php

namespace Illuminate\Events;

use Closure;
use Illuminate\Queue\SerializableClosureFactory;

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 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' => SerializableClosureFactory::make($this->closure),
                'arguments' => $arguments,
                'catch' => collect($this->catchCallbacks)->map(function ($callback) {
                    return SerializableClosureFactory::make($callback);
                })->all(),
            ]))->onConnection($this->connection)->onQueue($this->queue)->delay($this->delay);
        };
    }
}

cmd: