Class StepExecutionRequestHandler


  • @MessageEndpoint
    public class StepExecutionRequestHandler
    extends java.lang.Object
    A MessageEndpoint that can handle a StepExecutionRequest and return a StepExecution as the result. Typically these need to be aggregated into a response to a partition handler.
    Author:
    Dave Syer
    • Constructor Detail

      • StepExecutionRequestHandler

        public StepExecutionRequestHandler()
    • Method Detail

      • setStepLocator

        public void setStepLocator​(StepLocator stepLocator)
        Used to locate a Step to execute for each request.
        Parameters:
        stepLocator - a StepLocator
      • setJobExplorer

        public void setJobExplorer​(JobExplorer jobExplorer)
        An explorer that should be used to check for StepExecution completion.
        Parameters:
        jobExplorer - a JobExplorer that is linked to the shared repository used by all remote workers.