Class StepFactoryBean<I,O>
- java.lang.Object
- org.springframework.batch.core.configuration.xml.StepParserStepFactoryBean<I,O>
- org.springframework.batch.core.jsr.configuration.xml.StepFactoryBean<I,O>
- All Implemented Interfaces:
org.springframework.beans.factory.Aware
,org.springframework.beans.factory.BeanNameAware
,org.springframework.beans.factory.FactoryBean<Step>
public class StepFactoryBean<I,O> extends StepParserStepFactoryBean<I,O>
ThisFactoryBean
is used by the JSR-352 namespace parser to createStep
objects. It stores all of the properties that are configurable on the <step/>.- Since:
- 3.0
- Author:
- Michael Minella, Chris Schaefer
Constructor Summary
Constructors Constructor Description StepFactoryBean()
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Step
createPartitionStep()
protected TaskletStep
createTaskletStep()
protected FaultTolerantStepBuilder<I,O>
getFaultTolerantStepBuilder(java.lang.String stepName)
Step
getObject()
Create aStep
from the configuration provided.protected SimpleStepBuilder<I,O>
getSimpleStepBuilder(java.lang.String stepName)
void
setBatchPropertyContext(BatchPropertyContext context)
protected void
setChunk(SimpleStepBuilder<I,O> builder)
void
setPartitionReducer(javax.batch.api.partition.PartitionReducer reducer)
void
setPartitions(int partitions)
void
setStepChunkCompletionPolicy(java.lang.Object chunkCompletionPolicy)
Wraps aCheckpointAlgorithm
in aCheckpointAlgorithmAdapter
if required for consumption by the rest of the framework.void
setStepItemProcessor(java.lang.Object itemProcessor)
Wraps aItemProcessor
in aItemProcessorAdapter
if required for consumption by the rest of the framework.void
setStepItemReader(java.lang.Object itemReader)
Wraps aItemReader
in aItemReaderAdapter
if required for consumption by the rest of the framework.void
setStepItemWriter(java.lang.Object itemWriter)
Wraps aItemWriter
in aItemWriterAdapter
if required for consumption by the rest of the framework.void
setStepTasklet(java.lang.Object tasklet)
Wraps aBatchlet
in aBatchletAdapter
if required for consumption by the rest of the framework.void
setTimeout(java.lang.Integer timeout)
Methods inherited from class org.springframework.batch.core.configuration.xml.StepParserStepFactoryBean
createFaultTolerantStep, createFlowStep, createSimpleStep, enhanceCommonStep, enhanceTaskletStepBuilder, getCommitInterval, getCompletionPolicy, getJobRepository, getName, getObjectType, getPartitionHandler, getStepExecutionAggergator, getTasklet, getTransactionManager, hasChunkElement, hasPartitionElement, hasTasklet, isFaultTolerant, isSingleton, registerItemListeners, requiresTransactionManager, setAllowStartIfComplete, setBackOffPolicy, setBeanName, setCacheCapacity, setChunkCompletionPolicy, setCommitInterval, setFlow, setGridSize, setHasChunkElement, setIsolation, setIsReaderTransactionalQueue, setItemProcessor, setItemReader, setItemWriter, setJob, setJobLauncher, setJobParametersExtractor, setJobRepository, setKeyGenerator, setListeners, setName, setNoRollbackExceptionClasses, setPartitioner, setPartitionHandler, setPartitionLock, setPartitionQueue, setProcessorTransactional, setPropagation, setRetryableExceptionClasses, setRetryContextCache, setRetryLimit, setRetryListeners, setRetryPolicy, setSkipLimit, setSkippableExceptionClasses, setSkipPolicy, setStartLimit, setStep, setStepExecutionAggregator, setStreams, setTaskExecutor, setTasklet, setThrottleLimit, setTransactionManager, setTransactionTimeout, validateFaultTolerantSettings
Method Detail
setPartitionReducer
public void setPartitionReducer(javax.batch.api.partition.PartitionReducer reducer)
setBatchPropertyContext
public void setBatchPropertyContext(BatchPropertyContext context)
setPartitions
public void setPartitions(int partitions)
getObject
public Step getObject() throws java.lang.Exception
Create aStep
from the configuration provided.- Specified by:
getObject
in interfaceorg.springframework.beans.factory.FactoryBean<I>
- Overrides:
getObject
in classStepParserStepFactoryBean<I,O>
- Throws:
java.lang.Exception
- See Also:
FactoryBean.getObject()
createTaskletStep
protected TaskletStep createTaskletStep()
- Overrides:
createTaskletStep
in classStepParserStepFactoryBean<I,O>
- Returns:
- a new
TaskletStep
setChunk
protected void setChunk(SimpleStepBuilder<I,O> builder)
- Overrides:
setChunk
in classStepParserStepFactoryBean<I,O>
createPartitionStep
protected Step createPartitionStep()
- Overrides:
createPartitionStep
in classStepParserStepFactoryBean<I,O>
setStepTasklet
public void setStepTasklet(java.lang.Object tasklet)
Wraps aBatchlet
in aBatchletAdapter
if required for consumption by the rest of the framework.- Parameters:
tasklet
-Tasklet
orBatchlet
implementation- Throws:
java.lang.IllegalArgumentException
- if tasklet does not implement either Tasklet or Batchlet
setStepItemReader
public void setStepItemReader(java.lang.Object itemReader)
Wraps aItemReader
in aItemReaderAdapter
if required for consumption by the rest of the framework.- Parameters:
itemReader
-ItemReader
orItemReader
implementation- Throws:
java.lang.IllegalArgumentException
- if itemReader does not implement either version of ItemReader
setStepItemProcessor
public void setStepItemProcessor(java.lang.Object itemProcessor)
Wraps aItemProcessor
in aItemProcessorAdapter
if required for consumption by the rest of the framework.- Parameters:
itemProcessor
-ItemProcessor
orItemProcessor
implementation- Throws:
java.lang.IllegalArgumentException
- if itemProcessor does not implement either version of ItemProcessor
setStepItemWriter
public void setStepItemWriter(java.lang.Object itemWriter)
Wraps aItemWriter
in aItemWriterAdapter
if required for consumption by the rest of the framework.- Parameters:
itemWriter
-ItemWriter
orItemWriter
implementation- Throws:
java.lang.IllegalArgumentException
- if itemWriter does not implement either version of ItemWriter
setStepChunkCompletionPolicy
public void setStepChunkCompletionPolicy(java.lang.Object chunkCompletionPolicy)
Wraps aCheckpointAlgorithm
in aCheckpointAlgorithmAdapter
if required for consumption by the rest of the framework.- Parameters:
chunkCompletionPolicy
-CompletionPolicy
orCheckpointAlgorithm
implementation- Throws:
java.lang.IllegalArgumentException
- if chunkCompletionPolicy does not implement either CompletionPolicy or CheckpointAlgorithm
getFaultTolerantStepBuilder
protected FaultTolerantStepBuilder<I,O> getFaultTolerantStepBuilder(java.lang.String stepName)
- Overrides:
getFaultTolerantStepBuilder
in classStepParserStepFactoryBean<I,O>
getSimpleStepBuilder
protected SimpleStepBuilder<I,O> getSimpleStepBuilder(java.lang.String stepName)
- Overrides:
getSimpleStepBuilder
in classStepParserStepFactoryBean<I,O>
setTimeout
public void setTimeout(java.lang.Integer timeout)