程序包 org.springframework.batch.core.step.factory

类 SimpleStepFactoryBean<T,​S>

  • 所有已实现的接口:
    org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.FactoryBean<Step>
    直接已知子类:
    FaultTolerantStepFactoryBean
    public class SimpleStepFactoryBean<T,​S>
extends java.lang.Object
implements org.springframework.beans.factory.FactoryBean<Step>, org.springframework.beans.factory.BeanNameAware
    Most common configuration options for simple steps should be found here. Use this factory bean instead of creating a Step implementation manually. This factory does not support configuration of fault-tolerant behavior, use appropriate subclass of this factory bean to configure skip or retry.
    作者:
    Dave Syer, Robert Kasanicky
    另请参阅:
    FaultTolerantStepFactoryBean

    • 字段详细资料

      • logger

        protected final org.apache.commons.logging.Log logger

    • 方法详细资料

      • setIsReaderTransactionalQueue

        public void setIsReaderTransactionalQueue​(boolean isReaderTransactionalQueue)
        Flag to signal that the reader is transactional (usually a JMS consumer) so that items are re-presented after a rollback. The default is false and readers are assumed to be forward-only.
        参数:
        isReaderTransactionalQueue - the value of the flag

      • isReaderTransactionalQueue

        protected boolean isReaderTransactionalQueue()
        Convenience method for subclasses.
        返回:
        true if the flag is set (default false)

      • setBeanName

        public void setBeanName​(java.lang.String name)
        Set the bean name property, which will become the name of the Step when it is created.
        指定者:
        setBeanName 在接口中 org.springframework.beans.factory.BeanNameAware
        另请参阅:
        BeanNameAware.setBeanName(java.lang.String)

      • getName

        public java.lang.String getName()
        Public getter for the name of the step.
        返回:
        the name

      • setTransactionTimeout

        public void setTransactionTimeout​(int transactionTimeout)
        The timeout for an individual transaction in the step.
        参数:
        transactionTimeout - the transaction timeout to set, defaults to infinite

      • setPropagation

        public void setPropagation​(org.springframework.transaction.annotation.Propagation propagation)
        参数:
        propagation - the propagation to set for business transactions

      • setIsolation

        public void setIsolation​(org.springframework.transaction.annotation.Isolation isolation)
        参数:
        isolation - the isolation to set for business transactions

      • setStartLimit

        public void setStartLimit​(int startLimit)
        Public setter for the start limit for the step.
        参数:
        startLimit - the startLimit to set

      • setAllowStartIfComplete

        public void setAllowStartIfComplete​(boolean allowStartIfComplete)
        Public setter for the flag to indicate that the step should be replayed on a restart, even if successful the first time.
        参数:
        allowStartIfComplete - the shouldAllowStartIfComplete to set

      • setStreams

        public void setStreams​(ItemStream[] streams)
        The streams to inject into the Step. Any instance of ItemStream can be used, and will then receive callbacks at the appropriate stage in the step.
        参数:
        streams - an array of listeners

      • setListeners

        public void setListeners​(StepListener[] listeners)
        The listeners to inject into the Step. Any instance of StepListener can be used, and will then receive callbacks at the appropriate stage in the step.
        参数:
        listeners - an array of listeners

      • setTransactionManager

        public void setTransactionManager​(org.springframework.transaction.PlatformTransactionManager transactionManager)
        Public setter for the PlatformTransactionManager.
        参数:
        transactionManager - the transaction manager to set

      • getTransactionAttribute

        protected org.springframework.transaction.interceptor.TransactionAttribute getTransactionAttribute()
        Getter for the TransactionAttribute for subclasses only.
        返回:
        the transactionAttribute

      • getObject

        public final Step getObject()
                     throws java.lang.Exception
        Create a Step from the configuration provided.
        指定者:
        getObject 在接口中 org.springframework.beans.factory.FactoryBean<T>
        抛出:
        java.lang.Exception
        另请参阅:
        FactoryBean.getObject()

      • getObjectType

        public java.lang.Class<TaskletStep> getObjectType()
        指定者:
        getObjectType 在接口中 org.springframework.beans.factory.FactoryBean<T>

      • isSingleton

        public boolean isSingleton()
        Returns true by default, but in most cases a Step should not be treated as thread-safe. Clients are recommended to create a new step for each job execution.
        指定者:
        isSingleton 在接口中 org.springframework.beans.factory.FactoryBean<T>
        另请参阅:
        FactoryBean.isSingleton()

      • setSingleton

        public void setSingleton​(boolean singleton)
        Public setter for the singleton flag.
        参数:
        singleton - the value to set. Defaults to true.

      • setCommitInterval

        public void setCommitInterval​(int commitInterval)
        Set the commit interval. Either set this or the chunkCompletionPolicy but not both.
        参数:
        commitInterval - 1 by default

      • setChunkCompletionPolicy

        public void setChunkCompletionPolicy​(CompletionPolicy chunkCompletionPolicy)
        Public setter for the CompletionPolicy applying to the chunk level. A transaction will be committed when this policy decides to complete. Defaults to a SimpleCompletionPolicy with chunk size equal to the commitInterval property.
        参数:
        chunkCompletionPolicy - the chunkCompletionPolicy to set

      • getStepOperations

        protected RepeatOperations getStepOperations()
        Protected getter for the step operations to make them available in subclasses.
        返回:
        the step operations

      • setStepOperations

        public void setStepOperations​(RepeatOperations stepOperations)
        Public setter for the stepOperations.
        参数:
        stepOperations - the stepOperations to set

      • setChunkOperations

        public void setChunkOperations​(RepeatOperations chunkOperations)
        Public setter for the chunkOperations.
        参数:
        chunkOperations - the chunkOperations to set

      • getChunkOperations

        protected RepeatOperations getChunkOperations()
        Protected getter for the chunk operations to make them available in subclasses.
        返回:
        the step operations

      • setTaskExecutor

        public void setTaskExecutor​(org.springframework.core.task.TaskExecutor taskExecutor)
        Public setter for the TaskExecutor. If this is set, then it will be used to execute the chunk processing inside the Step.
        参数:
        taskExecutor - the taskExecutor to set

      • getTaskExecutor

        protected org.springframework.core.task.TaskExecutor getTaskExecutor()
        Make the TaskExecutor available to subclasses
        返回:
        the taskExecutor to be used to execute chunks

      • setThrottleLimit

        public void setThrottleLimit​(int throttleLimit)
        Public setter for the throttle limit. This limits the number of tasks queued for concurrent processing to prevent thread pools from being overwhelmed. Defaults to TaskExecutorRepeatTemplate.DEFAULT_THROTTLE_LIMIT.
        参数:
        throttleLimit - the throttle limit to set.