class ProcessorQueue extends Processor (View source)

Properties

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

Methods

__construct(TargetInterface $target)

No description

from Processor
registerTask(TaskInterface $task, $priority)

No description

from Processor
execute(ActionInterface $action)

No description

finish()

No description

getTasks()

No description

from Processor
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)

Parameters

TargetInterface $target

registerTask(TaskInterface $task, $priority)

Parameters

TaskInterface $task
$priority

execute(ActionInterface $action)

Parameters

ActionInterface $action

finish()

getTasks()

getTotalTasks()

process()

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

int getItemsPerBatch()

Return Value

int

setItemsPerBatch(int $itemsPerBatch)

Parameters

int $itemsPerBatch

setQueue(Queue $queue)

Parameters

Queue $queue

getQueue()

__sleep()

receive()