org.oddjob.jobs

Class GrabJob

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.BasePrimary

org.oddjob.jobs.GrabJob

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable, ArooaContextAware, ArooaSessionAware, PropertyChangeNotifier, Iconic, LogEnabled, Resettable, Stateful, Stoppable, Structural

public class GrabJob
extends BasePrimary
implements java.lang.Runnable, java.io.Serializable, Stoppable, Resettable, Stateful, Structural

Description

Grab work to do. By competing for work with other Grabbers this job facilitates distribution of work between multiple Oddjob processes.

Example

See the user guide.

See Also:

Serialized Form

Author:

rob

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GrabJob.LoosingAction Actions on loosing.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	stop stop flag.

Constructor Summary

Constructors

Constructor and Description
GrabJob() Constructor.

Method Summary

Modifier and Type	Method and Description
void	addStructuralListener(StructuralListener listener) Add a listener.
protected void	fireDestroyedState() Internal method to fire state.
java.lang.String	getIdentifier()
java.lang.Object	getInstance()
GrabJob.LoosingAction	getOnLoosing()
protected StateChanger<JobState>	getStateChanger()
java.lang.String	getWinner()
boolean	hardReset() Perform a hard reset on the job.
protected IconHelper	iconHelper() Subclasses must provide a IconHelper.
void	removeStructuralListener(StructuralListener listener) Remove a listener.
void	run()
void	setIdentifier(java.lang.String identifier)
void	setInstance(java.lang.Object instance)
void	setJob(java.lang.Runnable job) The child.
void	setKeeper(Keeper keeper)
void	setOnLoosing(GrabJob.LoosingAction loosingAction)
boolean	softReset() Perform a soft reset on the job.
protected JobStateHandler	stateHandler() Subclasses must provide a StateHandler.
void	stop() Stop executing.

Methods inherited from class org.oddjob.framework.extend.BasePrimary

configure, getName, logger, logger, loggerName, save, setName, toString

Methods inherited from class org.oddjob.framework.extend.BaseComponent

addIconListener, addPropertyChangeListener, addStateListener, configure, destroy, firePropertyChange, getArooaSession, iconForId, initialise, lastStateEvent, onConfigured, onDestroy, onInitialised, removeIconListener, removePropertyChangeListener, removeStateListener, save, setArooaContext, setArooaSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.oddjob.Stateful

addStateListener, lastStateEvent, removeStateListener

Field Detail

stop

protected transient volatile boolean stop

stop flag.

Constructor Detail

GrabJob

public GrabJob()

Constructor.

Method Detail

stateHandler

protected JobStateHandler stateHandler()

Description copied from class: BaseComponent

Subclasses must provide a StateHandler.

Specified by:

stateHandler in class BaseComponent

Returns:

A State Handler. Never null.

iconHelper

protected IconHelper iconHelper()

Description copied from class: BaseComponent

Subclasses must provide a IconHelper.

Specified by:

iconHelper in class BaseComponent

Returns:

An Icon Helper. Never null.

getStateChanger

protected StateChanger<JobState> getStateChanger()

run

public final void run()

Specified by:

run in interface java.lang.Runnable

stop

public void stop()
          throws FailedToStopException

Description copied from interface: Stoppable

Stop executing. This method should not return until the Stoppable has actually stopped.

Specified by:

stop in interface Stoppable

Throws:

FailedToStopException

softReset

public boolean softReset()

Perform a soft reset on the job.

Specified by:

softReset in interface Resettable

Returns:

true if successful.

hardReset

public boolean hardReset()

Perform a hard reset on the job.

Specified by:

hardReset in interface Resettable

Returns:

true if successful.

addStructuralListener

public void addStructuralListener(StructuralListener listener)

Add a listener. The listener will immediately receive add notifications for all existing children.

Specified by:

addStructuralListener in interface Structural

Parameters:

listener - The listener.

removeStructuralListener

public void removeStructuralListener(StructuralListener listener)

Remove a listener.

Specified by:

removeStructuralListener in interface Structural

Parameters:

listener - The listener.

setJob

public void setJob(java.lang.Runnable job)

The child.

Property: job

Description: The child job.

Required: No, but pointless if missing.

Parameters:

job - A child

setKeeper

public void setKeeper(Keeper keeper)

getIdentifier

public java.lang.String getIdentifier()

setIdentifier

public void setIdentifier(java.lang.String identifier)

getInstance

public java.lang.Object getInstance()

setInstance

public void setInstance(java.lang.Object instance)

getWinner

public java.lang.String getWinner()

getOnLoosing

public GrabJob.LoosingAction getOnLoosing()

setOnLoosing

public void setOnLoosing(GrabJob.LoosingAction loosingAction)

fireDestroyedState

protected void fireDestroyedState()

Internal method to fire state.

Specified by:

fireDestroyedState in class BaseComponent