step.functions.handler

Class FunctionMessageHandler

java.lang.Object

step.grid.agent.handler.AbstractMessageHandler

step.functions.handler.FunctionMessageHandler

All Implemented Interfaces:

step.grid.agent.handler.AgentContextAware, step.grid.agent.handler.MessageHandler

public class FunctionMessageHandler
extends step.grid.agent.handler.AbstractMessageHandler

Field Summary

Fields

Modifier and Type	Field and Description
static String	FUNCTION_HANDLER_KEY
static String	FUNCTION_HANDLER_PACKAGE_KEY
FunctionHandlerFactory	functionHandlerFactory

Fields inherited from class step.grid.agent.handler.AbstractMessageHandler

agentTokenServices

Constructor Summary

Constructors

Constructor and Description
FunctionMessageHandler()

Method Summary

Modifier and Type	Method and Description
protected void	addAdditionalMeasuresToOutput(step.functions.io.Output<?> output, List<step.core.reports.Measure> additionalMeasures)
protected void	addCustomTypeToOutputMeasures(List<step.core.reports.Measure> outputMeasures)
protected Map<String,Object>	customMeasureData()
step.grid.io.OutputMessage	handle(step.grid.agent.tokenpool.AgentTokenWrapper token, step.grid.io.InputMessage inputMessage)
void	init(step.grid.agent.AgentTokenServices agentTokenServices)

Methods inherited from class step.grid.agent.handler.AbstractMessageHandler

buildPropertyMap, getFileVersionId, retrieveFileVersion

Methods inherited from class java.lang.Object

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

Field Detail

FUNCTION_HANDLER_PACKAGE_KEY

public static final String FUNCTION_HANDLER_PACKAGE_KEY

See Also:

Constant Field Values

FUNCTION_HANDLER_KEY

public static final String FUNCTION_HANDLER_KEY

See Also:

Constant Field Values

functionHandlerFactory

public FunctionHandlerFactory functionHandlerFactory

Constructor Detail

FunctionMessageHandler

public FunctionMessageHandler()

Method Detail

init

public void init(step.grid.agent.AgentTokenServices agentTokenServices)

Specified by:

init in interface step.grid.agent.handler.AgentContextAware

Overrides:

init in class step.grid.agent.handler.AbstractMessageHandler

handle

public step.grid.io.OutputMessage handle(step.grid.agent.tokenpool.AgentTokenWrapper token,
                                         step.grid.io.InputMessage inputMessage)
                                  throws Exception

Throws:

Exception

addCustomTypeToOutputMeasures

protected void addCustomTypeToOutputMeasures(List<step.core.reports.Measure> outputMeasures)

addAdditionalMeasuresToOutput

protected void addAdditionalMeasuresToOutput(step.functions.io.Output<?> output,
                                             List<step.core.reports.Measure> additionalMeasures)

customMeasureData

protected Map<String,Object> customMeasureData()