Manager
class Manager mixin QueueManager mixin Queue
Traits
Properties
| static protected object|null | $instance | The current globally used instance. |
from CapsuleManagerTrait |
| protected Container | $container | The container instance. |
from CapsuleManagerTrait |
| protected QueueManager | $manager | The queue manager instance. |
Methods
Get the container used to resolve connector dependencies.
Get the exception reporter for in-process queue connections.
Setup the default queue configuration options.
Build the queue manager instance.
Register the default connectors that the component ships with.
Get a connection instance from the global manager.
Push a new job onto the queue.
Push an array of jobs onto the queue.
Push a new job onto the queue after (n) seconds.
Get a registered connection instance.
Register a connection with the manager.
Get the queue manager instance.
Pass dynamic instance methods to the manager.
Dynamically pass methods to the default connection.
Details
in
CapsuleManagerTrait at line 25
protected void
setupContainer(Container $container)
Setup the IoC container instance.
in
CapsuleManagerTrait at line 40
void
setAsGlobal()
Make this capsule instance available globally.
Boot or tests only. Swaps the global Capsule instance used by static calls; request-time use races across coroutines.
in
CapsuleManagerTrait at line 48
Container
getContainer()
Get the IoC container instance.
in
CapsuleManagerTrait at line 59
void
setContainer(Container $container)
Set the IoC container instance.
Boot or tests only. Swaps the Capsule container used by this standalone manager; request-time use races across coroutines.
in
CapsuleManagerTrait at line 67
static void
flushState()
Flush all static state.
at line 72
protected Container
connectorContainer()
Get the container used to resolve connector dependencies.
in
RegistersQueueConnectors at line 35
protected void
registerDefaultConnectors(QueueManager $manager)
Register the connectors on the queue manager.
in
RegistersQueueConnectors at line 45
protected Closure|null
exceptionReporter()
Get the exception reporter for in-process queue connections.
in
RegistersQueueConnectors at line 57
protected void
registerNullConnector(QueueManager $manager)
Register the Null queue connector.
in
RegistersQueueConnectors at line 65
protected void
registerSyncConnector(QueueManager $manager)
Register the Sync queue connector.
in
RegistersQueueConnectors at line 73
protected void
registerDeferredConnector(QueueManager $manager)
Register the Deferred queue connector.
in
RegistersQueueConnectors at line 81
protected void
registerBackgroundConnector(QueueManager $manager)
Register the Background queue connector.
in
RegistersQueueConnectors at line 89
protected void
registerFailoverConnector(QueueManager $manager)
Register the Failover queue connector.
in
RegistersQueueConnectors at line 100
protected void
registerDatabaseConnector(QueueManager $manager)
Register the database queue connector.
in
RegistersQueueConnectors at line 113
protected void
registerRedisConnector(QueueManager $manager)
Register the Redis queue connector.
in
RegistersQueueConnectors at line 126
protected void
registerBeanstalkdConnector(QueueManager $manager)
Register the Beanstalkd queue connector.
in
RegistersQueueConnectors at line 134
protected void
registerSqsConnector(QueueManager $manager)
Register the Amazon SQS queue connector.
at line 34
__construct(Container|null $container = null)
Create a new queue capsule manager.
at line 48
protected void
setupDefaultConfiguration()
Setup the default queue configuration options.
at line 56
protected void
setupManager()
Build the queue manager instance.
at line 64
protected void
registerConnectors()
Register the default connectors that the component ships with.
at line 80
static Queue
connection(UnitEnum|string|null $connection = null)
Get a connection instance from the global manager.
at line 88
static mixed
push(object|string $job, mixed $data = '', UnitEnum|string|null $queue = null, UnitEnum|string|null $connection = null)
Push a new job onto the queue.
at line 96
static mixed
bulk(array $jobs, mixed $data = '', UnitEnum|string|null $queue = null, UnitEnum|string|null $connection = null)
Push an array of jobs onto the queue.
at line 104
static mixed
later(DateInterval|DateTimeInterface|int $delay, object|string $job, mixed $data = '', UnitEnum|string|null $queue = null, UnitEnum|string|null $connection = null)
Push a new job onto the queue after (n) seconds.
at line 112
Queue
getConnection(UnitEnum|string|null $name = null)
Get a registered connection instance.
at line 120
void
addConnection(array $config, string $name = 'default')
Register a connection with the manager.
at line 128
QueueManager
getQueueManager()
Get the queue manager instance.
at line 136
mixed
__call(string $method, array $parameters)
Pass dynamic instance methods to the manager.
at line 144
static mixed
__callStatic(string $method, array $parameters)
Dynamically pass methods to the default connection.