class ProcessorQueue extends Processor (View source)

Properties

protected $target from  Processor
protected $tasks
protected $itemsPerBatch
protected $queue

Methods

__construct(TargetInterface $target)

No description

registerTask(TaskInterface $task, $priority = 0)

No description

execute(ActionInterface $action)

No description

finish()

No description

getTasks()

No description

getTotalTasks()

No description

process()

Takes the current queue, and fills it based on the currently registered tasks and the registered processor.

int
getItemsPerBatch()

No description

setItemsPerBatch(int $itemsPerBatch)

No description

setQueue(Queue $queue)

No description

getQueue()

No description

__sleep()

No description

receive()

No description

Details

__construct(TargetInterface $target)

No description

Parameters

TargetInterface $target

registerTask(TaskInterface $task, $priority = 0)

No description

Parameters

TaskInterface $task
$priority

execute(ActionInterface $action)

No description

Parameters

ActionInterface $action

finish()

No description

getTasks()

No description

getTotalTasks()

No description

process()

Takes the current queue, and fills it based on the currently registered tasks and the registered processor.

int getItemsPerBatch()

No description

Return Value

int

setItemsPerBatch(int $itemsPerBatch)

No description

Parameters

int $itemsPerBatch

setQueue(Queue $queue)

No description

Parameters

Queue $queue

getQueue()

No description

__sleep()

No description

receive()

No description