$name
$name : string
Queue name
Queue class
$adapter : \Pop\Queue\Adapter\AdapterInterface
Queue adapter
$application : \Pop\Application
Application object
$workers : array<mixed,\Pop\Queue\Processor\Worker>
Queue workers
$schedulers : array<mixed,\Pop\Queue\Processor\Scheduler>
Queue schedulers
__construct(string $name, \Pop\Queue\Adapter\AdapterInterface $adapter, \Pop\Application $application = null)
Constructor
Instantiate the queue object
string | $name | |
\Pop\Queue\Adapter\AdapterInterface | $adapter | |
\Pop\Application | $application |
load(string $name, \Pop\Queue\Adapter\AdapterInterface $adapter, \Pop\Application $application = null) : \Pop\Queue\Queue
Load queue from adapter
string | $name | |
\Pop\Queue\Adapter\AdapterInterface | $adapter | |
\Pop\Application | $application |
adapter() : \Pop\Queue\Adapter\AdapterInterface
Get the adapter
application() : \Pop\Application
Get the application
addWorker(\Pop\Queue\Processor\Worker $worker) : \Pop\Queue\Queue
Add a worker
\Pop\Queue\Processor\Worker | $worker |
addWorkers(array $workers) : \Pop\Queue\Queue
Add workers
array | $workers |
addScheduler(\Pop\Queue\Processor\Scheduler $scheduler) : \Pop\Queue\Queue
Add a scheduler
\Pop\Queue\Processor\Scheduler | $scheduler |
addSchedulers(array $schedulers) : \Pop\Queue\Queue
Add schedulers
array | $schedulers |
processSchedulers() : \Pop\Queue\Queue
Process schedulers in the queue
processWorkers() : \Pop\Queue\Queue
Process schedulers in the queue
processAll() : \Pop\Queue\Queue
Process all schedulers and workers in the queue