Package net.officefloor.frame.test

Class BackPressureTeamSource

java.lang.Object

net.officefloor.frame.api.team.source.impl.AbstractTeamSource

net.officefloor.frame.test.BackPressureTeamSource

All Implemented Interfaces:

TeamSource, Team

public class BackPressureTeamSource
extends AbstractTeamSource
implements Team

TeamSource that causes back pressure to be applied.

Author:

Daniel Sagenschneider

Nested Class Summary

Nested classes/interfaces inherited from class net.officefloor.frame.api.team.source.impl.AbstractTeamSource

AbstractTeamSource.SpecificationContext

Field Summary

Fields

Modifier and Type	Field	Description
static final RejectedExecutionException	BACK_PRESSURE_EXCEPTION	RejectedExecutionException thrown to indicate back pressure.

Constructor Summary

Constructors

Constructor	Description
BackPressureTeamSource()

Method Summary

Modifier and Type	Method	Description
void	assignJob(Job job)	Assigns a Job to be executed by this Team.
Team	createTeam(TeamSourceContext context)	Creates the Team.
static int	getBackPressureEscalationCount()	Obtains the number of back pressure Escalation instances that have occurred.
protected void	loadSpecification(AbstractTeamSource.SpecificationContext context)	Overridden to load specification.
static void	resetBackPressureEscalationCount(int count)	Resets the back pressure Escalation count.
void	startWorking()	Indicates for the Team to start working.
void	stopWorking()	Indicates for the Team to stop working.

Methods inherited from class net.officefloor.frame.api.team.source.impl.AbstractTeamSource

getSpecification

Methods inherited from class java.lang.Object

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

Field Details

BACK_PRESSURE_EXCEPTION

public static final RejectedExecutionException BACK_PRESSURE_EXCEPTION

RejectedExecutionException thrown to indicate back pressure.

Constructor Details

BackPressureTeamSource

public BackPressureTeamSource()

Method Details

getBackPressureEscalationCount

public static int getBackPressureEscalationCount()

Obtains the number of back pressure Escalation instances that have occurred.

Returns:

Number of back pressure Escalation instances that have occurred.

resetBackPressureEscalationCount

public static void resetBackPressureEscalationCount(int count)

Resets the back pressure Escalation count.

Parameters:

count - Count to reset the Escalation count.

loadSpecification

protected void loadSpecification(AbstractTeamSource.SpecificationContext context)

Description copied from class: AbstractTeamSource

Overridden to load specification.

Specified by:

loadSpecification in class AbstractTeamSource

Parameters:

context - AbstractTeamSource.SpecificationContext.

createTeam

public Team createTeam(TeamSourceContext context)
                throws Exception

Description copied from interface: TeamSource

Creates the Team.

Specified by:

createTeam in interface TeamSource

Parameters:

context - TeamSourceContext.

Returns:

Team.

Throws:

Exception - If fails to configure the TeamSource.

startWorking

public void startWorking()

Description copied from interface: Team

Indicates for the Team to start working.

Specified by:

startWorking in interface Team

assignJob

public void assignJob(Job job)

Description copied from interface: Team

Assigns a Job to be executed by this Team.

Specified by:

assignJob in interface Team

Parameters:

job - Job.

stopWorking

public void stopWorking()

Description copied from interface: Team

Indicates for the Team to stop working.

This method should block and only return control when the Team has stopped working and is no longer assigned Job instances to complete.

Specified by:

stopWorking in interface Team