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 Details

  • Constructor Details

    • FunctionMessageHandler

      public FunctionMessageHandler()

  • Method Details

    • 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()