Package 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 Description static java.lang.String
FUNCTION_HANDLER_KEY
static java.lang.String
FUNCTION_HANDLER_PACKAGE_KEY
FunctionHandlerFactory
functionHandlerFactory
-
Constructor Summary
Constructors Constructor Description FunctionMessageHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
addAdditionalMeasuresToOutput(step.functions.io.Output<?> output, java.util.List<step.core.reports.Measure> additionalMeasures)
protected void
addCustomTypeToOutputMeasures(java.util.List<step.core.reports.Measure> outputMeasures)
protected java.util.Map<java.lang.String,java.lang.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)
-
-
-
Field Detail
-
FUNCTION_HANDLER_PACKAGE_KEY
public static final java.lang.String FUNCTION_HANDLER_PACKAGE_KEY
- See Also:
- Constant Field Values
-
FUNCTION_HANDLER_KEY
public static final java.lang.String FUNCTION_HANDLER_KEY
- See Also:
- Constant Field Values
-
functionHandlerFactory
public FunctionHandlerFactory functionHandlerFactory
-
-
Method Detail
-
init
public void init(step.grid.agent.AgentTokenServices agentTokenServices)
- Specified by:
init
in interfacestep.grid.agent.handler.AgentContextAware
- Overrides:
init
in classstep.grid.agent.handler.AbstractMessageHandler
-
handle
public step.grid.io.OutputMessage handle(step.grid.agent.tokenpool.AgentTokenWrapper token, step.grid.io.InputMessage inputMessage) throws java.lang.Exception
- Throws:
java.lang.Exception
-
addCustomTypeToOutputMeasures
protected void addCustomTypeToOutputMeasures(java.util.List<step.core.reports.Measure> outputMeasures)
-
addAdditionalMeasuresToOutput
protected void addAdditionalMeasuresToOutput(step.functions.io.Output<?> output, java.util.List<step.core.reports.Measure> additionalMeasures)
-
customMeasureData
protected java.util.Map<java.lang.String,java.lang.Object> customMeasureData()
-
-