Package org.opencastproject.terminationstate.api

Class AbstractJobTerminationStateService

java.lang.Object

org.opencastproject.terminationstate.api.AbstractJobTerminationStateService

All Implemented Interfaces:

TerminationStateService

Direct Known Subclasses:

AutoScalingTerminationStateService, TerminationStateServiceImpl

public abstract class AbstractJobTerminationStateService
extends Object
implements TerminationStateService

AbstractJobTerminationStateService. Abstract implementation of of TerminationStateService API which checks whether there are any jobs running before changing the termination state from WAIT to READY once a termination notification has been received.

Nested Class Summary

Nested classes/interfaces inherited from interface org.opencastproject.terminationstate.api.TerminationStateService

TerminationStateService.TerminationState

Constructor Summary

Constructors

Constructor	Description
AbstractJobTerminationStateService()

Method Summary

Modifier and Type	Method	Description
protected long	countJobs()	Count the current number of jobs this node is processing
protected ServiceRegistry	getServiceRegistry()
TerminationStateService.TerminationState	getState()
protected boolean	readyToTerminate()	If waiting and no jobs running change the state to ready
void	setServiceRegistry(ServiceRegistry service)	OSGI dependency injection of service registry
void	setState(TerminationStateService.TerminationState state)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractJobTerminationStateService

public AbstractJobTerminationStateService()

Method Details

setState

public void setState(TerminationStateService.TerminationState state)

Specified by:

setState in interface TerminationStateService

getState

public TerminationStateService.TerminationState getState()

Specified by:

getState in interface TerminationStateService

countJobs

protected long countJobs()
                  throws ServiceRegistryException

Count the current number of jobs this node is processing

Returns:

number jobs

Throws:

ServiceRegistryException

readyToTerminate

protected boolean readyToTerminate()

If waiting and no jobs running change the state to ready

Returns:

ready to terminate

setServiceRegistry

public void setServiceRegistry(ServiceRegistry service)

OSGI dependency injection of service registry

Parameters:

service - ServiceRegistry instance

getServiceRegistry

protected ServiceRegistry getServiceRegistry()