CallQueuedHandler
class CallQueuedHandler (View source)
Properties
| protected Dispatcher | $dispatcher | The bus dispatcher implementation. |
|
| protected Container | $container | The container instance. |
|
| protected mixed | $runningCommand | The command currently being processed. |
Methods
Get the command from the given payload.
Dispatch the given job / command through its specified middleware.
Set the job instance of the given class if necessary.
Ensure the next job in the chain is dispatched if applicable.
Ensure the batch is notified of the successful job completion.
Ensure the lock for a unique job is released.
Determine if the debounced command was superseded by a newer dispatch.
Handle a debounced (superseded) job by firing an event and deleting it.
Determine if the given command should be unique.
Determine if the given command should be unique until processing begins.
Ensure the lock for a unique job is released via context.
Record a potentially batched job as successful when deleted because models were missing.
Ensure the batch is notified of the failed job.
Ensure the chained job catch callbacks are invoked.
Get the command currently being processed.
Details
__construct(Dispatcher $dispatcher, Container $container)
Create a new handler instance.
void
call(Job $job, array $data)
Handle the queued job.
protected mixed
getCommand(array $data)
Get the command from the given payload.
protected mixed
dispatchThroughMiddleware(Job $job, mixed $command)
Dispatch the given job / command through its specified middleware.
protected mixed
resolveHandler(Job $job, mixed $command)
Resolve the handler for the given command.
protected mixed
setJobInstanceIfNecessary(Job $job, mixed $instance)
Set the job instance of the given class if necessary.
protected void
ensureNextJobInChainIsDispatched(mixed $command)
Ensure the next job in the chain is dispatched if applicable.
protected void
ensureSuccessfulBatchJobIsRecorded(mixed $command)
Ensure the batch is notified of the successful job completion.
protected void
ensureUniqueJobLockIsReleased(mixed $command)
Ensure the lock for a unique job is released.
protected bool
commandShouldBeDebounced(mixed $command)
Determine if the debounced command was superseded by a newer dispatch.
protected void
deleteDebouncedJob(Job $job, mixed $command)
Handle a debounced (superseded) job by firing an event and deleting it.
protected bool
commandShouldBeUnique(mixed $command)
Determine if the given command should be unique.
protected bool
commandShouldBeUniqueUntilProcessing(mixed $command)
Determine if the given command should be unique until processing begins.
protected void
ensureUniqueJobLockIsReleasedViaContext()
Ensure the lock for a unique job is released via context.
This is required when we can't unserialize the job due to missing models.
protected void
ensureSuccessfulBatchJobIsRecordedForMissingModel(Job $job, string $class)
Record a potentially batched job as successful when deleted because models were missing.
void
failed(array $data, Throwable|null $e, string $uuid, Job|null $job = null)
Call the failed method on the job instance.
The exception that caused the failure will be passed.
protected void
ensureFailedBatchJobIsRecorded(string $uuid, mixed $command, Throwable $e)
Ensure the batch is notified of the failed job.
protected void
ensureChainCatchCallbacksAreInvoked(string $uuid, mixed $command, Throwable $e)
Ensure the chained job catch callbacks are invoked.
mixed
getRunningCommand()
Get the command currently being processed.
Laravel Cloud is the best place to deploy Laravel, Nuxt, Express, Hono, Node.js, Bun, Go, Flask, Python, and more, with dedicated infrastructure available on AWS through Laravel Private Cloud.