seda.sandStorm.internal
Class StageWrapper

java.lang.Object
  seda.sandStorm.internal.StageWrapper

All Implemented Interfaces:

StageWrapperIF

 class StageWrapper
extends java.lang.Object
implements StageWrapperIF

A StageWrapper is a basic implementation of StageWrapperIF for application-level stages.

Field Summary

private ConfigDataIF	config
private FiniteQueue	eventQ
private EventHandlerIF	handler
private java.lang.String	name
private ResponseTimeControllerIF	rtcon
private StageIF	stage
private StageStatsIF	stats
private ThreadManagerIF	threadmgr

Constructor Summary

StageWrapper(ManagerIF mgr, java.lang.String name, EventHandlerIF handler, ConfigDataIF config, ThreadManagerIF threadmgr)
Create a StageWrapper with the given name, handler, config data, and thread manager.

StageWrapper(ManagerIF mgr, java.lang.String name, EventHandlerIF handler, ConfigDataIF config, ThreadManagerIF threadmgr, int queueThreshold)
Create a StageWrapper with the given name, handler, config data, thread manager, and queue threshold.

Method Summary

private void	createRTController(ManagerIF mgr)
void	destroy() Destroy this stage.
EventHandlerIF	getEventHandler() Return the event handler associated with this stage.
ResponseTimeControllerIF	getResponseTimeController() Return the response time controller, if any.
SourceIF	getSource() Return the set of sources from which events should be pulled to pass to this EventHandlerIF.
StageIF	getStage() Return the stage handle for this stage.
StageStatsIF	getStats() Return execution statistics for this stage.
ThreadManagerIF	getThreadManager() Return the thread manager which will run this stage.
void	init() Initialize this stage.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

name

private java.lang.String name

stage

private StageIF stage

handler

private EventHandlerIF handler

config

private ConfigDataIF config

eventQ

private FiniteQueue eventQ

threadmgr

private ThreadManagerIF threadmgr

stats

private StageStatsIF stats

rtcon

private ResponseTimeControllerIF rtcon

Constructor Detail

StageWrapper

StageWrapper(ManagerIF mgr,
             java.lang.String name,
             EventHandlerIF handler,
             ConfigDataIF config,
             ThreadManagerIF threadmgr)

Create a StageWrapper with the given name, handler, config data, and thread manager.

StageWrapper

StageWrapper(ManagerIF mgr,
             java.lang.String name,
             EventHandlerIF handler,
             ConfigDataIF config,
             ThreadManagerIF threadmgr,
             int queueThreshold)

Create a StageWrapper with the given name, handler, config data, thread manager, and queue threshold.

Method Detail

createRTController

private void createRTController(ManagerIF mgr)

init

public void init()
          throws java.lang.Exception

Initialize this stage.

Specified by:

init in interface StageWrapperIF

Throws:

java.lang.Exception

destroy

public void destroy()
             throws java.lang.Exception

Destroy this stage.

Specified by:

destroy in interface StageWrapperIF

Throws:

java.lang.Exception

getEventHandler

public EventHandlerIF getEventHandler()

Return the event handler associated with this stage.

Specified by:

getEventHandler in interface StageWrapperIF

getStage

public StageIF getStage()

Return the stage handle for this stage.

Specified by:

getStage in interface StageWrapperIF

getSource

public SourceIF getSource()

Return the set of sources from which events should be pulled to pass to this EventHandlerIF.

Specified by:

getSource in interface StageWrapperIF

getThreadManager

public ThreadManagerIF getThreadManager()

Return the thread manager which will run this stage.

Specified by:

getThreadManager in interface StageWrapperIF

getStats

public StageStatsIF getStats()

Return execution statistics for this stage.

Specified by:

getStats in interface StageWrapperIF

getResponseTimeController

public ResponseTimeControllerIF getResponseTimeController()

Return the response time controller, if any.

Specified by:

getResponseTimeController in interface StageWrapperIF

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object