Package org.opencastproject.serviceregistry.impl

Class JobDispatcher

java.lang.Object

org.opencastproject.serviceregistry.impl.JobDispatcher

public class JobDispatcher
extends Object

This dispatcher implementation will check for jobs in the QUEUED Job.Status. If new jobs are found, the dispatcher will attempt to dispatch each job to the least loaded service.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	JobDispatcher.JobDispatcherRunner

Field Summary

Fields

Modifier and Type	Field	Description
protected org.opencastproject.db.DBSession	db
protected org.opencastproject.db.DBSessionFactory	dbSessionFactory
protected final Map<Long,String>	dispatchPriorityList	The dispatcher priority list
protected static final String	OPT_DISPATCHINTERVAL	Configuration key for the dispatch interval, in seconds
static final String	PERSISTENCE_UNIT	JPA persistence unit name
protected ScheduledThreadPoolExecutor	scheduledExecutor	The thread pool to use for dispatching.

Constructor Summary

Constructors

Constructor	Description
JobDispatcher()

Method Summary

Modifier and Type	Method	Description
void	activate(org.osgi.service.component.ComponentContext cc)
void	modified(org.osgi.service.component.ComponentContext cc)
void	setDBSessionFactory(org.opencastproject.db.DBSessionFactory dbSessionFactory)	OSGi DI
void	updated(Dictionary properties)

Methods inherited from class java.lang.Object

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

Field Details

PERSISTENCE_UNIT

public static final String PERSISTENCE_UNIT

JPA persistence unit name

See Also:

• Constant Field Values

OPT_DISPATCHINTERVAL

protected static final String OPT_DISPATCHINTERVAL

Configuration key for the dispatch interval, in seconds

See Also:

• Constant Field Values

scheduledExecutor

protected ScheduledThreadPoolExecutor scheduledExecutor

The thread pool to use for dispatching.

dbSessionFactory

protected org.opencastproject.db.DBSessionFactory dbSessionFactory

db

protected org.opencastproject.db.DBSession db

dispatchPriorityList

protected final Map<Long,String> dispatchPriorityList

The dispatcher priority list

Constructor Details

JobDispatcher

public JobDispatcher()

Method Details

setDBSessionFactory

public void setDBSessionFactory(org.opencastproject.db.DBSessionFactory dbSessionFactory)

OSGi DI

activate

public void activate(org.osgi.service.component.ComponentContext cc)
              throws org.osgi.service.cm.ConfigurationException

Throws:

org.osgi.service.cm.ConfigurationException

modified

public void modified(org.osgi.service.component.ComponentContext cc)
              throws org.osgi.service.cm.ConfigurationException

Throws:

org.osgi.service.cm.ConfigurationException

updated

public void updated(Dictionary properties)

See Also:

• ManagedService.updated(java.util.Dictionary)