class QueueFactory implements Factory

Methods

__construct(Closure $factory)

Expects a callback that will be called to instantiate the queue adapter, once requested by the application.

Queue
connection(string $name = null)

Resolve a queue connection instance.

bool
isPaused(string $connection, string $queue)

Determine if a queue is paused.

array
getPausedQueues(string $connection, array $queues)

Determine which of the given queues are currently paused.

void
pause(string $connection, string $queue)

Pause a queue by its connection and name.

void
pauseFor(string $connection, string $queue, DateTimeInterface|DateInterval|int $ttl)

Pause a queue by its connection and name for a given amount of time.

void
resume(string $connection, string $queue)

Resume a paused queue by its connection and name.

void
withoutInterruptionPolling()

Indicate that queue workers should not poll for restart or pause signals.

Details

__construct(Closure $factory)

Expects a callback that will be called to instantiate the queue adapter, once requested by the application.

Parameters

Closure $factory

Queue connection(string $name = null)

Resolve a queue connection instance.

Parameters

string $name

Return Value

Queue

bool isPaused(string $connection, string $queue)

Determine if a queue is paused.

Parameters

string $connection
string $queue

Return Value

bool

array getPausedQueues(string $connection, array $queues)

Determine which of the given queues are currently paused.

Parameters

string $connection
array $queues

Return Value

array

void pause(string $connection, string $queue)

Pause a queue by its connection and name.

Parameters

string $connection
string $queue

Return Value

void

void pauseFor(string $connection, string $queue, DateTimeInterface|DateInterval|int $ttl)

Pause a queue by its connection and name for a given amount of time.

Parameters

string $connection
string $queue
DateTimeInterface|DateInterval|int $ttl

Return Value

void

void resume(string $connection, string $queue)

Resume a paused queue by its connection and name.

Parameters

string $connection
string $queue

Return Value

void

void withoutInterruptionPolling()

Indicate that queue workers should not poll for restart or pause signals.

Return Value

void