クラス SimpleStepFactoryBean<T,S>

メソッドの詳細

• setIsReaderTransactionalQueue

  public void setIsReaderTransactionalQueue(boolean isReaderTransactionalQueue)

  ロールバック後にアイテムが再表示されるように、リーダーがトランザクション対応（通常は JMS コンシューマー）であることを示すフラグ。デフォルトは false で、リーダーは前方専用であると見なされます。

  パラメーター:

  isReaderTransactionalQueue - フラグの値

• isReaderTransactionalQueue

  protected boolean isReaderTransactionalQueue()

  サブクラスの簡易メソッド。

  戻り値:

  フラグが設定されている場合は true (デフォルトは false)

• setBeanName

  public void setBeanName(StringSE name)

  Bean name プロパティを設定します。これは、作成時に Step の名前になります。

  次で指定:

  インターフェース org.springframework.beans.factory.BeanNameAware の setBeanName 

  関連事項:

  • BeanNameAware.setBeanName(java.lang.String)

• getName

  public StringSE getName()

  ステップの名前のパブリック getter。

  戻り値:

  名前

• setTransactionTimeout

  public void setTransactionTimeout(int transactionTimeout)

  ステップ内の個々のトランザクションのタイムアウト。

  パラメーター:

  transactionTimeout - 設定するトランザクションタイムアウト、デフォルトは無限

• setPropagation

  public void setPropagation(org.springframework.transaction.annotation.Propagation propagation)

  パラメーター:

  propagation - ビジネストランザクションに設定する伝播

• setIsolation

  public void setIsolation(org.springframework.transaction.annotation.Isolation isolation)

  パラメーター:

  isolation - ビジネストランザクションに設定する分離

• setStartLimit

  public void setStartLimit(int startLimit)

  ステップの開始制限のパブリック setter。

  パラメーター:

  startLimit - 設定する startLimit

• setAllowStartIfComplete

  public void setAllowStartIfComplete(boolean allowStartIfComplete)

  初めて成功した場合でも、再起動時にステップを再生する必要があることを示すフラグのパブリック setter。

  パラメーター:

  allowStartIfComplete - 設定する shouldAllowStartIfComplete

• setItemReader

  public void setItemReader(ItemReader<? extends T> itemReader)

  パラメーター:

  itemReader - 設定する ItemReader

• setItemWriter

  public void setItemWriter(ItemWriter<? super S> itemWriter)

  パラメーター:

  itemWriter - 設定する ItemWriter

• setItemProcessor

  public void setItemProcessor(ItemProcessor<? super T,? extends S> itemProcessor)

  パラメーター:

  itemProcessor - 設定する ItemProcessor

• setStreams

  public void setStreams(ItemStream[] streams)

  Step に注入するストリーム。ItemStream の任意のインスタンスを使用でき、ステップの適切な段階でコールバックを受信します。

  パラメーター:

  streams - リスナーの配列

• setListeners

  public void setListeners(StepListener[] listeners)

  Step に注入するリスナー。StepListener の任意のインスタンスを使用でき、ステップの適切な段階でコールバックを受信します。

  パラメーター:

  listeners - リスナーの配列

• getListeners

  protected StepListener[] getListeners()

  StepListener の保護された getter。

  戻り値:

  リスナー

• getItemReader

  protected ItemReader<? extends T> getItemReader()

  サブクラスが使用する ItemReader の保護された getter。

  戻り値:

  itemReader

• getItemWriter

  protected ItemWriter<? super S> getItemWriter()

  サブクラスが使用する ItemWriter の保護された getter

  戻り値:

  itemWriter

• getItemProcessor

  protected ItemProcessor<? super T,? extends S> getItemProcessor()

  サブクラスが使用する ItemProcessor の保護された getter

  戻り値:

  itemProcessor

• setJobRepository

  public void setJobRepository(JobRepository jobRepository)

  JobRepository のパブリック setter。

  パラメーター:

  jobRepository - 必須の依存関係です（デフォルトなし）。

• setObservationRegistry

  public void setObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)

  ObservationRegistry のパブリック setter。

  パラメーター:

  observationRegistry - オプションの依存関係です (デフォルトは ObservationRegistry.NOOP)。

• setTransactionManager

  public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

  PlatformTransactionManager の公開 setter。

  パラメーター:

  transactionManager - 設定するトランザクションマネージャー

• getTransactionAttribute

  protected org.springframework.transaction.interceptor.TransactionAttribute getTransactionAttribute()

  Getter（サブクラスの TransactionAttribute のみ）。

  戻り値:

  transactionAttribute

• getObject

  public final Step getObject() throws ExceptionSE

  提供された構成から Step を作成します。

  次で指定:

  インターフェース org.springframework.beans.factory.FactoryBean<T> の getObject 

  例外:

  ExceptionSE

  関連事項:

  • FactoryBean.getObject()

• createBuilder

  protected SimpleStepBuilder<T,S> createBuilder(StringSE name)

• getObjectType

  public ClassSE<TaskletStep> getObjectType()

  次で指定:

  インターフェース org.springframework.beans.factory.FactoryBean<T> の getObjectType 

• isSingleton

  public boolean isSingleton()

  デフォルトでは true を返しますが、ほとんどの場合、Step はスレッドセーフとして扱われるべきで はありません。クライアントは、ジョブの実行ごとに新しいステップを作成することをお勧めします。

  次で指定:

  インターフェース org.springframework.beans.factory.FactoryBean<T> の isSingleton 

  関連事項:

  • FactoryBean.isSingleton()

• setSingleton

  public void setSingleton(boolean singleton)

  シングルトンフラグのパブリック setter。

  パラメーター:

  singleton - 設定する値。デフォルトは true です。

• setCommitInterval

  public void setCommitInterval(int commitInterval)

  コミット間隔を設定します。これまたは chunkCompletionPolicy のいずれかを設定しますが、両方を設定することはできません。

  パラメーター:

  commitInterval - デフォルトで 1

• setChunkCompletionPolicy

  public void setChunkCompletionPolicy(CompletionPolicy chunkCompletionPolicy)

  チャンクレベルに適用する CompletionPolicy のパブリック setter。このポリシーが完了すると、トランザクションがコミットされます。チャンクサイズが commitInterval プロパティと等しい SimpleCompletionPolicy がデフォルトです。

  パラメーター:

  chunkCompletionPolicy - 設定する chunkCompletionPolicy

• getStepOperations

  protected RepeatOperations getStepOperations()

  ステップ操作がサブクラスで使用できるようにするための保護された getter。

  戻り値:

  ステップ操作

• setStepOperations

  public void setStepOperations(RepeatOperations stepOperations)

  stepOperations のパブリック setter。

  パラメーター:

  stepOperations - 設定する stepOperations

• setChunkOperations

  public void setChunkOperations(RepeatOperations chunkOperations)

  chunkOperations のパブリック setter。

  パラメーター:

  chunkOperations - 設定するチャンク操作

• getChunkOperations

  protected RepeatOperations getChunkOperations()

  チャンク操作がサブクラスで使用できるようにするための保護された getter。

  戻り値:

  ステップ操作

• setExceptionHandler

  public void setExceptionHandler(ExceptionHandler exceptionHandler)

  ExceptionHandler のパブリック setter。

  パラメーター:

  exceptionHandler - 設定する exceptionHandler

• getExceptionHandler

  protected ExceptionHandler getExceptionHandler()

  ExceptionHandler の保護された getter。

  戻り値:

  ExceptionHandler

• setTaskExecutor

  public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

  TaskExecutor のパブリック setter。これを設定すると、Step 内のチャンク処理を実行するために使用されます。

  パラメーター:

  taskExecutor - 設定する taskExecutor

• getTaskExecutor

  protected org.springframework.core.task.TaskExecutor getTaskExecutor()

  TaskExecutor をサブクラスで使用できるようにする

  戻り値:

  チャンクの実行に使用される taskExecutor

• setThrottleLimit

  @DeprecatedSE(since="5.0", forRemoval=true) public void setThrottleLimit(int throttleLimit)

  非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

  5.0 以降、6.0 で削除予定。代わりに、タスクキューの容量が制限されたプールされた TaskExecutor 実装を使用します。

  スロットル制限のパブリック setter。これにより、並行処理のためにキューに入れられるタスクの数が制限され、スレッドプールがオーバーロードになるのを防ぎます。デフォルトは TaskExecutorRepeatTemplate.DEFAULT_THROTTLE_LIMIT です。

  パラメーター:

  throttleLimit - 設定するスロットル制限。

• applyConfiguration

  protected void applyConfiguration(SimpleStepBuilder<T,S> builder)