Package io.github.jchejarla.springbatch.clustering.api

Interface ClusterAwareAggregatorCallback

public interface ClusterAwareAggregatorCallback
A callback interface to be implemented by classes that need to react to the successful completion or failure of a collection of Spring Batch partitioned step executions in a clustered environment.

This interface allows for custom logic to be executed once all partitions have finished, providing a centralized point to handle outcomes.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onFailure(Collection<org.springframework.batch.core.step.StepExecution> executions)
    Called when at least one of the partitioned step executions has failed.
    void
    onSuccess(Collection<org.springframework.batch.core.step.StepExecution> executions)
    Called when all partitioned step executions have completed successfully.

  • Method Details

    • onSuccess

      void onSuccess(Collection<org.springframework.batch.core.step.StepExecution> executions)
      Called when all partitioned step executions have completed successfully.
      Parameters:
      executions - A collection of StepExecution instances from the partitioned steps that all completed successfully.

    • onFailure

      void onFailure(Collection<org.springframework.batch.core.step.StepExecution> executions)
      Called when at least one of the partitioned step executions has failed.
      Parameters:
      executions - A collection of StepExecution instances from the partitioned steps, including any that may have failed.