com.ten60.netkernel.scheduler
Class Scheduler

java.lang.Object
  com.ten60.netkernel.urii.representation.SimpleRepresentationImpl
      com.ten60.netkernel.container.ComponentImpl
          com.ten60.netkernel.scheduler.Scheduler

All Implemented Interfaces:

IComponent, IAspectBinaryStream, IURAspect, IURRepresentation, IURRequestee, IURRequestor, IURSynchRequestee

public final class Scheduler
extends ComponentImpl
implements IURRequestee, IURSynchRequestee, IURRequestor

The Scheduler system component. Responsible for taking a request from a transport or accessor and mapping it to an accessor and then executing that accessor.

Field Summary

static URIdentifier

URI

Fields inherited from class com.ten60.netkernel.urii.representation.SimpleRepresentationImpl

mMeta

Constructor Summary

Scheduler()
Creates a new instance of Scheduler

Method Summary

void	doPeriodicHouseKeeping() doPeriodicHouseKeeping method implemented with null body
Debugger	getDebugger()
RequestState	getPendingStateFor(URRequest aRequest)
int	killSession(long aSession, java.lang.String aId)
protected void	processRequest()
protected void	processRequest(RequestState aState)
void	receiveAsyncException(URResult aResult) A callback when execution of a previous request has failed
void	receiveAsyncResult(URResult aResult) A callback when a result to a previous request is available
void	releaseBreakpointedState(RequestState aState)
void	requestAsync(URRequest aRequest) Make an asynchronous request
URResult	requestSynch(URRequest aRequest) make a synchronous request
void	start(Container aContainer) start method implemented with null body
void	stop() stop method implemented with null body
void	write(java.io.OutputStream aStream) write method implemented with null body

Methods inherited from class com.ten60.netkernel.container.ComponentImpl

getEncoding, getURI

Methods inherited from class com.ten60.netkernel.urii.representation.SimpleRepresentationImpl

getAspect, getAspects, getMeta, hasAspect

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ten60.netkernel.urii.IURRepresentation

getAspect, getAspects, getMeta, hasAspect

Field Detail

URI

public static final URIdentifier URI

Constructor Detail

Scheduler

public Scheduler()

Creates a new instance of Scheduler

Method Detail

getDebugger

public Debugger getDebugger()

getPendingStateFor

public RequestState getPendingStateFor(URRequest aRequest)

requestSynch

public URResult requestSynch(URRequest aRequest)
                      throws NetKernelException

Description copied from interface: IURSynchRequestee

make a synchronous request

Specified by:

requestSynch in interface IURSynchRequestee

Parameters:

aRequest - the request being made

Returns:

the result of the request if it was sucessful

Throws:

NetKernelException - thrown if the request was unsuccessful for any reason

requestAsync

public void requestAsync(URRequest aRequest)

Description copied from interface: IURRequestee

Make an asynchronous request

Specified by:

requestAsync in interface IURRequestee

Parameters:

aRequest - the request being made

start

public void start(Container aContainer)
           throws NetKernelException

Description copied from class: ComponentImpl

start method implemented with null body

Specified by:

start in interface IComponent

Overrides:

start in class ComponentImpl

Parameters:

aContainer - the container we will execute inside

Throws:

NetKernelException - thrown if we encounter any error during startup

stop

public void stop()

Description copied from class: ComponentImpl

stop method implemented with null body

Specified by:

stop in interface IComponent

Overrides:

stop in class ComponentImpl

releaseBreakpointedState

public void releaseBreakpointedState(RequestState aState)

processRequest

protected void processRequest()

processRequest

protected void processRequest(RequestState aState)

receiveAsyncResult

public void receiveAsyncResult(URResult aResult)

Description copied from interface: IURRequestor

A callback when a result to a previous request is available

Specified by:

receiveAsyncResult in interface IURRequestor

Parameters:

aResult - the result of a previous request

receiveAsyncException

public void receiveAsyncException(URResult aResult)

Description copied from interface: IURRequestor

A callback when execution of a previous request has failed

Specified by:

receiveAsyncException in interface IURRequestor

Parameters:

aResult - the exception result of a previous request

write

public void write(java.io.OutputStream aStream)
           throws java.io.IOException

Description copied from class: ComponentImpl

write method implemented with null body

Specified by:

write in interface IAspectBinaryStream

Overrides:

write in class ComponentImpl

Parameters:

aStream - the output stream

Throws:

java.io.IOException - thrown if we fail to write

killSession

public int killSession(long aSession,
                       java.lang.String aId)
                throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

doPeriodicHouseKeeping

public void doPeriodicHouseKeeping()

Description copied from class: ComponentImpl

doPeriodicHouseKeeping method implemented with null body

Specified by:

doPeriodicHouseKeeping in interface IComponent

Overrides:

doPeriodicHouseKeeping in class ComponentImpl