org.springframework.batch.integration.partition
Class StepExecutionRequestHandler

java.lang.Object
  org.springframework.batch.integration.partition.StepExecutionRequestHandler

@MessageEndpoint
public class StepExecutionRequestHandler
extends 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 Summary

StepExecutionRequestHandler()

Method Summary

StepExecution	handle(StepExecutionRequest request)
void	setJobExplorer(JobExplorer jobExplorer) An explorer that should be used to check for StepExecution completion.
void	setStepLocator(StepLocator stepLocator) Used to locate a Step to execute for each request.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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.

handle

@ServiceActivator
public StepExecution handle(StepExecutionRequest request)