class JobManager

Methods

__construct(Registry $managerRegistry, EventDispatcherInterface $eventDispatcher, RetryScheduler $retryScheduler)

No description

findJob($command, array $args = array())

No description

getJob($command, array $args = array())

No description

getOrCreateIfNotExists($command, array $args = array())

No description

findStartableJob($workerName, array $excludedIds = array(), $excludedQueues = array(), $restrictedQueues = array())

No description

findAllForRelatedEntity($relatedEntity)

No description

findOpenJobForRelatedEntity($command, $relatedEntity)

No description

findJobForRelatedEntity($command, $relatedEntity, array $states = array())

No description

findPendingJob(array $excludedIds = array(), array $excludedQueues = array(), array $restrictedQueues = array())

No description

closeJob(Job $job, $finalState)

No description

Job[]
findIncomingDependencies(Job $job)

No description

Job[]
getIncomingDependencies(Job $job)

No description

findLastJobsWithError($nbJobs = 10)

No description

getAvailableQueueList()

No description

getAvailableJobsForQueueCount($jobQueue)

No description

Details

at line 41
__construct(Registry $managerRegistry, EventDispatcherInterface $eventDispatcher, RetryScheduler $retryScheduler)

Parameters

Registry $managerRegistry
EventDispatcherInterface $eventDispatcher
RetryScheduler $retryScheduler

at line 48
findJob($command, array $args = array())

Parameters

$command
array $args

at line 57
getJob($command, array $args = array())

Parameters

$command
array $args

at line 66
getOrCreateIfNotExists($command, array $args = array())

Parameters

$command
array $args

at line 96
findStartableJob($workerName, array $excludedIds = array(), $excludedQueues = array(), $restrictedQueues = array())

Parameters

$workerName
array $excludedIds
$excludedQueues
$restrictedQueues

at line 133
findAllForRelatedEntity($relatedEntity)

Parameters

$relatedEntity

at line 146
findOpenJobForRelatedEntity($command, $relatedEntity)

Parameters

$command
$relatedEntity

at line 151
findJobForRelatedEntity($command, $relatedEntity, array $states = array())

Parameters

$command
$relatedEntity
array $states

at line 196
findPendingJob(array $excludedIds = array(), array $excludedQueues = array(), array $restrictedQueues = array())

Parameters

array $excludedIds
array $excludedQueues
array $restrictedQueues

at line 233
closeJob(Job $job, $finalState)

Parameters

Job $job
$finalState

at line 356
Job[] findIncomingDependencies(Job $job)

Parameters

Job $job

Return Value

Job[]

at line 371
Job[] getIncomingDependencies(Job $job)

Parameters

Job $job

Return Value

Job[]

at line 392
findLastJobsWithError($nbJobs = 10)

Parameters

$nbJobs

at line 400
getAvailableQueueList()

at line 417
getAvailableJobsForQueueCount($jobQueue)

Parameters

$jobQueue