Package org.opencastproject.serviceregistry.impl

Class JobDispatcher.JobDispatcherRunner

java.lang.Object

org.opencastproject.serviceregistry.impl.JobDispatcher.JobDispatcherRunner

All Implemented Interfaces:

Runnable

Enclosing class:

JobDispatcher

public class JobDispatcher.JobDispatcherRunner
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor	Description
JobDispatcherRunner()

Method Summary

Modifier and Type	Method	Description
protected Function<javax.persistence.EntityManager,List<Long>>	getDispatchableJobsWithIdFilterQuery(Set<Long> jobIds)	Return dispatchable job ids, where the job status is RESTART or QUEUED and the job id is listed in the given set.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JobDispatcherRunner

public JobDispatcherRunner()

Method Details

run

public void run()

Specified by:

run in interface Runnable

See Also:

• Thread.run()

getDispatchableJobsWithIdFilterQuery

protected Function<javax.persistence.EntityManager,List<Long>> getDispatchableJobsWithIdFilterQuery(Set<Long> jobIds)

Return dispatchable job ids, where the job status is RESTART or QUEUED and the job id is listed in the given set.

Parameters:

jobIds - set with job id's interested in

Returns:

list with dispatchable job id's from the given set, with job status RESTART or QUEUED