class QueueFactory implements Factory
Methods
Expects a callback that will be called to instantiate the queue adapter, once requested by the application.
Determine which of the given queues are currently paused.
Pause a queue by its connection and name for a given amount of time.
The names of the queues currently paused on the given connection.
Indicate that queue workers should not poll for restart or pause signals.
Details
at
line 32
__construct(Closure $factory, Repository|null $cache = null, Dispatcher|null $events = null)
Expects a callback that will be called to instantiate the queue adapter, once requested by the application.
at
line 45
Queue
connection(string $name = null)
Resolve a queue connection instance.
at
line 72
bool
isPaused(string $connection, string $queue)
Determine if a queue is paused.
at
line 91
array
getPausedQueues(string $connection, array $queues)
Determine which of the given queues are currently paused.
at
line 106
void
pause(string $connection, string $queue)
Pause a queue by its connection and name.
at
line 123
void
pauseFor(string $connection, string $queue, DateTimeInterface|DateInterval|int $ttl)
Pause a queue by its connection and name for a given amount of time.
at
line 139
void
resume(string $connection, string $queue)
Resume a paused queue by its connection and name.
at
line 158
array
pausedQueues(string|null $connection)
The names of the queues currently paused on the given connection.
This is a Flarum addition over Illuminate's surface, powering the admin dashboard warning. Pauses are tracked when made through this factory; entries whose underlying pause has expired (pauseFor) or was cleared externally are filtered out.
at
line 171
protected void
trackPausedQueue(string|null $connection, string $queue)
at
line 181
protected void
untrackPausedQueue(string|null $connection, string $queue)
at
line 197
void
withoutInterruptionPolling()
Indicate that queue workers should not poll for restart or pause signals.