Class RemoteStepExecutionAggregator

  • All Implemented Interfaces:
    StepExecutionAggregator, org.springframework.beans.factory.InitializingBean

    public class RemoteStepExecutionAggregator
    extends java.lang.Object
    implements StepExecutionAggregator, org.springframework.beans.factory.InitializingBean
    Convenience class for aggregating a set of StepExecution instances when the input comes from remote steps, so the data need to be refreshed from the repository.
    Since:
    2.1
    Author:
    Dave Syer
    • Constructor Detail

      • RemoteStepExecutionAggregator

        public RemoteStepExecutionAggregator()
        Create a new instance (useful for configuration purposes).
      • RemoteStepExecutionAggregator

        public RemoteStepExecutionAggregator​(JobExplorer jobExplorer)
        Create a new instance with a job explorer that can be used to refresh the data when aggregating.
        Parameters:
        jobExplorer - the JobExplorer to use
    • Method Detail

      • setJobExplorer

        public void setJobExplorer​(JobExplorer jobExplorer)
        Parameters:
        jobExplorer - the jobExplorer to set
      • setDelegate

        public void setDelegate​(StepExecutionAggregator delegate)
        Parameters:
        delegate - the delegate to set
      • afterPropertiesSet

        public void afterPropertiesSet()
                                throws java.lang.Exception
        Specified by:
        afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
        Throws:
        java.lang.Exception - if the job explorer is not provided