I
- 入力項目の型 O
- 出力項目の型 public class RemoteChunkingManagerStepBuilder<I,O> extends FaultTolerantStepBuilder<I,O>
ChunkMessageChannelItemWriter
を作成および設定します。messagingTemplate(MessagingTemplate)
を介して messagingTemplate
が提供されない場合、このビルダーは、outputChannel(MessageChannel)
を介して提供される outputChannel
にデフォルトチャンネルを作成して設定します。
messagingTemplate
が提供される場合、完全に構成され、そのデフォルトチャネルはワーカーへのリクエストが送信される出力チャネルに設定されていると想定されます。
StepBuilderHelper.CommonStepProperties
chunkListeners
logger, properties
コンストラクターと説明 |
---|
RemoteChunkingManagerStepBuilder(java.lang.String stepName) 新しい RemoteChunkingManagerStepBuilder を作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
RemoteChunkingManagerStepBuilder<I, O> | allowStartIfComplete(boolean allowStartIfComplete) |
RemoteChunkingManagerStepBuilder<I, O> | backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) アイテムがすぐに再試行されないようにバックオフポリシーを提供します(例: |
TaskletStep | build() マネージャー TaskletStep を作成します。 |
RemoteChunkingManagerStepBuilder<I, O> | chunk(CompletionPolicy completionPolicy) チャンク処理の補完ポリシーを設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | chunk(int chunkSize) このステップのチャンクサイズまたはコミット間隔を設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | chunkOperations(RepeatOperations repeatTemplate) chunk size または completion policy の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。 |
RemoteChunkingManagerStepBuilder<I, O> | exceptionHandler(ExceptionHandler exceptionHandler) タスクレットが失敗した場合に使用する例外ハンドラーを設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | inputChannel(org.springframework.messaging.PollableChannel inputChannel) ワーカーからの応答を受信する入力チャネルを設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | keyGenerator(KeyGenerator keyGenerator) 再試行されたアイテムを識別するためのキージェネレーターを設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | listener(ChunkListener listener) チャンクリスナーを登録します。 |
RemoteChunkingManagerStepBuilder<I, O> | listener(ItemReadListener<? super I> listener) アイテムリーダーリスナーを登録します。 |
RemoteChunkingManagerStepBuilder<I, O> | listener(ItemWriteListener<? super O> listener) アイテムライターリスナーを登録します。 |
RemoteChunkingManagerStepBuilder<I, O> | listener(java.lang.Object listener) アノテーションベースのリスナー構成を使用してオブジェクトを登録します。 |
RemoteChunkingManagerStepBuilder<I, O> | listener(org.springframework.retry.RetryListener listener) 再試行リスナーを登録します。 |
RemoteChunkingManagerStepBuilder<I, O> | listener(SkipListener<? super I,? super O> listener) スキップリスナーを登録します。 |
RemoteChunkingManagerStepBuilder<I, O> | listener(StepExecutionListener listener) |
RemoteChunkingManagerStepBuilder<I, O> | maxWaitTimeouts(int maxWaitTimeouts) リモートワーカーからの null 以外の結果をステップの最後で待機する最大回数。 |
RemoteChunkingManagerStepBuilder<I, O> | messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate) ワーカーにデータを送信するために使用する MessagingTemplate を設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | noRetry(java.lang.Class<? extends java.lang.Throwable> type) 再試行から除外する例外(およびサブクラス)を明示的に要求します。 |
RemoteChunkingManagerStepBuilder<I, O> | noRollback(java.lang.Class<? extends java.lang.Throwable> type) アイテムの読み取りまたは処理中に、この例外を無視可能としてマークします。 |
RemoteChunkingManagerStepBuilder<I, O> | noSkip(java.lang.Class<? extends java.lang.Throwable> type) 特定の例外(およびサブクラス)のスキップを明示的に防止します。 |
RemoteChunkingManagerStepBuilder<I, O> | outputChannel(org.springframework.messaging.MessageChannel outputChannel) ワーカーへのリクエストが送信される出力チャネルを設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | processor(ItemProcessor<? super I,? extends O> itemProcessor) アイテムのストリームを処理または変換するアイテムプロセッサー。 |
RemoteChunkingManagerStepBuilder<I, O> | reader(ItemReader<? extends I> reader) アイテムのストリームを提供するアイテムリーダー。 |
RemoteChunkingManagerStepBuilder<I, O> | readerIsTransactionalQueue() リーダーがトランザクション(通常はキュー)であることを示すフラグを設定します。つまり、失敗したアイテムはロールバックされ、後続のトランザクションで再表示される可能性があります。 |
RemoteChunkingManagerStepBuilder<I, O> | repository(JobRepository jobRepository) |
RemoteChunkingManagerStepBuilder<I, O> | retry(java.lang.Class<? extends java.lang.Throwable> type) 再試行する例外(およびサブクラス)を明示的に要求します。 |
RemoteChunkingManagerStepBuilder<I, O> | retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache) 明示的な再試行コンテキストキャッシュを提供します。 |
RemoteChunkingManagerStepBuilder<I, O> | retryLimit(int retryLimit) 失敗したアイテムを試行する最大回数。 |
RemoteChunkingManagerStepBuilder<I, O> | retryPolicy(org.springframework.retry.RetryPolicy retryPolicy) 他の場所で提供される FaultTolerantStepBuilder.retryLimit(int) および再試行可能な例外を使用する代わりに、明示的な再試行ポリシーを提供します。 |
RemoteChunkingManagerStepBuilder<I, O> | skip(java.lang.Class<? extends java.lang.Throwable> type) 特定の例外(およびサブクラス)をスキップすることを明示的にリクエストします。 |
RemoteChunkingManagerStepBuilder<I, O> | skipLimit(int skipLimit) ステップが失敗する前にスキップする失敗アイテムの最大数を設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | skipPolicy(SkipPolicy skipPolicy) スキップを管理するための明示的なポリシーを提供します。 |
RemoteChunkingManagerStepBuilder<I, O> | startLimit(int startLimit) |
RemoteChunkingManagerStepBuilder<I, O> | stepOperations(RepeatOperations repeatTemplate) タスクレットの実行を繰り返すために使用する繰り返しテンプレートを設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | stream(ItemStream stream) リスタートデータを管理するコールバックのストリームを登録します。 |
RemoteChunkingManagerStepBuilder<I, O> | throttleLimit(long throttleLimit) スロットル制限のパブリック setter。 |
RemoteChunkingManagerStepBuilder<I, O> | transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute) タスクレット実行のトランザクション属性を設定します。 |
RemoteChunkingManagerStepBuilder<I, O> | transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
RemoteChunkingManagerStepBuilder<I, O> | writer(ItemWriter<? super O> writer) リモートチャンク設定のマネージャーステップのアイテムライターは ChunkMessageChannelItemWriter のインスタンスに自動的に設定されるため、このメソッドは UnsupportedOperationException をスローします。 |
createChunkProcessor, createChunkProvider, createRetryOperations, createSkipPolicy, createTasklet, detectStreamInReader, faultTolerant, getChunkMonitor, getFatalExceptionAwareProxy, getJsrRetryListeners, getRollbackClassifier, getSkipListeners, listener, processorNonTransactional, registerStepListenerAsSkipListener
createChunkOperations, getChunkCompletionPolicy, getChunkSize, getItemListeners, getProcessor, getReader, getWriter, isReaderTransactionalQueue, listener, processor, registerAsStreamsAndListeners, registerStepListenerAsItemListener
concurrent, getExceptionHandler, getStepOperations, getStreams, getTaskExecutor, getThrottleLimit, getTransactionAttribute, registerStepListenerAsChunkListener, taskExecutor, throttleLimit
enhance, getJobRepository, getName, getTransactionManager, isAllowStartIfComplete
public RemoteChunkingManagerStepBuilder(java.lang.String stepName)
RemoteChunkingManagerStepBuilder
を作成します。stepName
- マネージャーステップの名前 public RemoteChunkingManagerStepBuilder<I,O> inputChannel(org.springframework.messaging.PollableChannel inputChannel)
ChunkMessageChannelItemWriter
の応答チャネルとして設定されます。inputChannel
- 入力チャンネル ChunkMessageChannelItemWriter.setReplyChannel(org.springframework.messaging.PollableChannel)
public RemoteChunkingManagerStepBuilder<I,O> outputChannel(org.springframework.messaging.MessageChannel outputChannel)
この setter または messagingTemplate(MessagingTemplate)
のいずれかを使用して、完全に構成されたメッセージングテンプレートを提供します。
outputChannel
- 出力チャンネル。messagingTemplate(MessagingTemplate)
public RemoteChunkingManagerStepBuilder<I,O> messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate)
MessagingTemplate
を設定します。メッセージングテンプレートのデフォルトチャネルを設定する必要があります この setter を使用して、完全に構成されたメッセージングテンプレートを提供するか、outputChannel(MessageChannel)
を介して出力チャネルを提供すると、デフォルトのメッセージングテンプレートが作成されます。
messagingTemplate
- 使用するメッセージングテンプレート outputChannel(MessageChannel)
public RemoteChunkingManagerStepBuilder<I,O> maxWaitTimeouts(int maxWaitTimeouts)
maxWaitTimeouts
- 待機タイムアウトの最大数 ChunkMessageChannelItemWriter.setMaxWaitTimeouts(int)
public RemoteChunkingManagerStepBuilder<I,O> throttleLimit(long throttleLimit)
throttleLimit
- 設定するスロットル制限 ChunkMessageChannelItemWriter.setThrottleLimit(long)
public TaskletStep build()
TaskletStep
を作成します。FaultTolerantStepBuilder<I, O>
の build
RemoteChunkHandlerFactoryBean
public RemoteChunkingManagerStepBuilder<I,O> reader(ItemReader<? extends I> reader)
SimpleStepBuilder
AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。デフォルトでは非トランザクションと見なされます。SimpleStepBuilder<I, O>
の reader
reader
- アイテムリーダー SimpleStepBuilder.readerTransactionalQueue
public RemoteChunkingManagerStepBuilder<I,O> repository(JobRepository jobRepository)
StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>>
の repository
public RemoteChunkingManagerStepBuilder<I,O> transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>>
の transactionManager
public RemoteChunkingManagerStepBuilder<I,O> listener(java.lang.Object listener)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の listener
listener
- リスナーアノテーションで設定されたメソッドを持つオブジェクト public RemoteChunkingManagerStepBuilder<I,O> listener(SkipListener<? super I,? super O> listener)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の listener
listener
- 登録するリスナー public RemoteChunkingManagerStepBuilder<I,O> listener(ChunkListener listener)
AbstractTaskletStepBuilder
FaultTolerantStepBuilder<I, O>
の listener
listener
- 登録するリスナー public RemoteChunkingManagerStepBuilder<I,O> transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)
AbstractTaskletStepBuilder
FaultTolerantStepBuilder<I, O>
の transactionAttribute
transactionAttribute
- トランザクション属性セット public RemoteChunkingManagerStepBuilder<I,O> listener(org.springframework.retry.RetryListener listener)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の listener
listener
- 登録するリスナー public RemoteChunkingManagerStepBuilder<I,O> keyGenerator(KeyGenerator keyGenerator)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の keyGenerator
keyGenerator
- ステートフルな再試行のための鍵ジェネレーター public RemoteChunkingManagerStepBuilder<I,O> retryLimit(int retryLimit)
FaultTolerantStepBuilder
FaultTolerantStepBuilder.retryPolicy
が設定されている場合は無視されます。FaultTolerantStepBuilder<I, O>
の retryLimit
retryLimit
- 再試行制限 (デフォルトは 0)public RemoteChunkingManagerStepBuilder<I,O> retryPolicy(org.springframework.retry.RetryPolicy retryPolicy)
FaultTolerantStepBuilder
FaultTolerantStepBuilder.retryLimit(int)
を使用する代わりに、明示的な再試行ポリシーと、他の場所で提供される再試行可能な例外を提供します。たとえば、異なる例外を異なる回数再試行するために使用できます。FaultTolerantStepBuilder<I, O>
の retryPolicy
retryPolicy
- 再試行ポリシー public RemoteChunkingManagerStepBuilder<I,O> backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)
FaultTolerantStepBuilder
FaultTolerantStepBuilder.retryPolicy
が設定されている場合は無視されます。FaultTolerantStepBuilder<I, O>
の backOffPolicy
backOffPolicy
- 使用するバックオフポリシー (デフォルトではバックオフなし)public RemoteChunkingManagerStepBuilder<I,O> retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の retryContextCache
retryContextCache
- トランザクション間の再試行コンテキストのキャッシュ (デフォルトで標準のインメモリ実装に)public RemoteChunkingManagerStepBuilder<I,O> skipLimit(int skipLimit)
FaultTolerantStepBuilder
FaultTolerantStepBuilder.skipPolicy(SkipPolicy)
が提供されている場合は無視されます。FaultTolerantStepBuilder<I, O>
の skipLimit
skipLimit
- 設定するスキップ制限 public RemoteChunkingManagerStepBuilder<I,O> noSkip(java.lang.Class<? extends java.lang.Throwable> type)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の noSkip
type
- スキップ不可の例外 public RemoteChunkingManagerStepBuilder<I,O> skip(java.lang.Class<? extends java.lang.Throwable> type)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の skip
type
- 例外型。public RemoteChunkingManagerStepBuilder<I,O> skipPolicy(SkipPolicy skipPolicy)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の skipPolicy
skipPolicy
- スキップポリシー public RemoteChunkingManagerStepBuilder<I,O> noRollback(java.lang.Class<? extends java.lang.Throwable> type)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の noRollback
type
- ロールバックなしとしてマークする例外 public RemoteChunkingManagerStepBuilder<I,O> noRetry(java.lang.Class<? extends java.lang.Throwable> type)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の noRetry
type
- 再試行から除外する例外 public RemoteChunkingManagerStepBuilder<I,O> retry(java.lang.Class<? extends java.lang.Throwable> type)
FaultTolerantStepBuilder
FaultTolerantStepBuilder<I, O>
の retry
type
- 再試行する例外 public RemoteChunkingManagerStepBuilder<I,O> stream(ItemStream stream)
AbstractTaskletStepBuilder
FaultTolerantStepBuilder<I, O>
の stream
stream
- 登録するストリーム public RemoteChunkingManagerStepBuilder<I,O> chunk(int chunkSize)
SimpleStepBuilder
SimpleStepBuilder.completionPolicy
との互換性はありません。SimpleStepBuilder<I, O>
の chunk
chunkSize
- チャンクサイズ (別名コミット間隔)public RemoteChunkingManagerStepBuilder<I,O> chunk(CompletionPolicy completionPolicy)
SimpleStepBuilder
chunk size
(またはコミット間隔)だけの場合よりも詳細に制御されます。SimpleStepBuilder<I, O>
の chunk
completionPolicy
- チャンクの補完ポリシー public RemoteChunkingManagerStepBuilder<I,O> writer(ItemWriter<? super O> writer) throws java.lang.UnsupportedOperationException
ChunkMessageChannelItemWriter
のインスタンスに自動的に設定されるため、このメソッドは UnsupportedOperationException
をスローします。リモートチャンクのマネージャーステップを構築する場合、アイテムライターを提供する必要はありません。SimpleStepBuilder<I, O>
の writer
writer
- アイテムライター java.lang.UnsupportedOperationException
- アイテムライターが提供されている場合 ChunkMessageChannelItemWriter
, RemoteChunkHandlerFactoryBean.setChunkWriter(ItemWriter)
public RemoteChunkingManagerStepBuilder<I,O> readerIsTransactionalQueue()
SimpleStepBuilder
SimpleStepBuilder<I, O>
の readerIsTransactionalQueue
public RemoteChunkingManagerStepBuilder<I,O> listener(ItemReadListener<? super I> listener)
SimpleStepBuilder
SimpleStepBuilder<I, O>
の listener
listener
- 登録するリスナー public RemoteChunkingManagerStepBuilder<I,O> listener(ItemWriteListener<? super O> listener)
SimpleStepBuilder
SimpleStepBuilder<I, O>
の listener
listener
- 登録するリスナー public RemoteChunkingManagerStepBuilder<I,O> chunkOperations(RepeatOperations repeatTemplate)
SimpleStepBuilder
chunk size
または completion policy
の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。SimpleStepBuilder<I, O>
の chunkOperations
repeatTemplate
- チャンクの完全な繰り返しテンプレート public RemoteChunkingManagerStepBuilder<I,O> exceptionHandler(ExceptionHandler exceptionHandler)
AbstractTaskletStepBuilder
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の exceptionHandler
exceptionHandler
- 例外ハンドラー public RemoteChunkingManagerStepBuilder<I,O> stepOperations(RepeatOperations repeatTemplate)
AbstractTaskletStepBuilder
AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>
の stepOperations
repeatTemplate
- 反復のためのルールを持つ繰り返しテンプレート public RemoteChunkingManagerStepBuilder<I,O> startLimit(int startLimit)
StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>>
の startLimit
public RemoteChunkingManagerStepBuilder<I,O> listener(StepExecutionListener listener)
StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>>
の listener
public RemoteChunkingManagerStepBuilder<I,O> allowStartIfComplete(boolean allowStartIfComplete)
StepBuilderHelper<AbstractTaskletStepBuilder<SimpleStepBuilder<I, O>>>
の allowStartIfComplete
public RemoteChunkingManagerStepBuilder<I,O> processor(ItemProcessor<? super I,? extends O> itemProcessor)
SimpleStepBuilder
AbstractTaskletStepBuilder.stream(ItemStream)
またはリスナーとして自動的に登録されます。SimpleStepBuilder<I, O>
の processor
itemProcessor
- アイテムプロセッサー