クラス RemoteChunkingManagerStepBuilder<I,O>

メソッドの詳細

• inputChannel

  public RemoteChunkingManagerStepBuilder<I,O> inputChannel(org.springframework.messaging.PollableChannel inputChannel)

  ワーカーからの応答を受信する入力チャネルを設定します。提供された入力チャネルは、このビルダーによって作成された ChunkMessageChannelItemWriter の応答チャネルとして設定されます。

  パラメーター:

  inputChannel - 入力チャンネル

  戻り値:

  流れるような連鎖のためのこのビルダーインスタンス

  関連事項:

  • ChunkMessageChannelItemWriter.setReplyChannel(org.springframework.messaging.PollableChannel)

• outputChannel

  public RemoteChunkingManagerStepBuilder<I,O> outputChannel(org.springframework.messaging.MessageChannel outputChannel)

  ワーカーへのリクエストが送信される出力チャネルを設定します。この setter を使用することにより、デフォルトのメッセージングテンプレートが作成され、出力チャネルがデフォルトチャネルとして設定されます。

  この setter または messagingTemplate(MessagingTemplate) のいずれかを使用して、完全に構成されたメッセージングテンプレートを提供します。

  パラメーター:

  outputChannel - 出力チャンネル。

  戻り値:

  流れるような連鎖のためのこのビルダーインスタンス

  関連事項:

  • messagingTemplate(MessagingTemplate)

• messagingTemplate

  public RemoteChunkingManagerStepBuilder<I,O> messagingTemplate(org.springframework.integration.core.MessagingTemplate messagingTemplate)

  ワーカーにデータを送信するために使用する MessagingTemplate を設定します。メッセージングテンプレートのデフォルトチャネルを設定する必要があります

  この setter を使用して、完全に構成されたメッセージングテンプレートを提供するか、outputChannel(MessageChannel) を介して出力チャネルを提供すると、デフォルトのメッセージングテンプレートが作成されます。

  パラメーター:

  messagingTemplate - 使用するメッセージングテンプレート

  戻り値:

  流れるような連鎖のためのこのビルダーインスタンス

  関連事項:

  • outputChannel(MessageChannel)

• maxWaitTimeouts

  public RemoteChunkingManagerStepBuilder<I,O> maxWaitTimeouts(int maxWaitTimeouts)

  リモートワーカーからの null 以外の結果をステップの終わりに待機する最大回数。これは、ゲートウェイで個別に設定された受信タイムアウトの乗数です。理想的な値は、遅いワーカー時間の終了を許可することと、デッドワーカーが存在する場合の応答性との間の妥協点です。デフォルトは 40 です。

  パラメーター:

  maxWaitTimeouts - 待機タイムアウトの最大数

  戻り値:

  流れるような連鎖のためのこのビルダーインスタンス

  関連事項:

  • ChunkMessageChannelItemWriter.setMaxWaitTimeouts(int)

• throttleLimit

  public RemoteChunkingManagerStepBuilder<I,O> throttleLimit(long throttleLimit)

  スロットル制限のパブリック setter。これにより、チャンク処理の保留中のリクエストの数が制限され、レシーバーがオーバーロードにならないようにします。

  パラメーター:

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

  戻り値:

  流れるような連鎖のためのこのビルダーインスタンス

  関連事項:

  • ChunkMessageChannelItemWriter.setThrottleLimit(long)

• build

  public TaskletStep build()

  マネージャー TaskletStep を作成します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の build 

  戻り値:

  構成されたマネージャーのステップ

  関連事項:

  • RemoteChunkHandlerFactoryBean

• reader

  public RemoteChunkingManagerStepBuilder<I,O> reader(ItemReader<? extends I> reader)

  クラスからコピーされた説明: SimpleStepBuilder

  アイテムのストリームを提供するアイテムリーダー。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream) またはリスナーとして自動的に登録されます。デフォルトでは非トランザクションと見なされます。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の reader 

  パラメーター:

  reader - アイテムリーダー

  戻り値:

  流れるようなチェーン用

  関連事項:

  • SimpleStepBuilder.readerTransactionalQueue

• repository

  @DeprecatedSE(since="5.1", forRemoval=true) public RemoteChunkingManagerStepBuilder<I,O> repository(JobRepository jobRepository)

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

  RemoteChunkingManagerStepBuilder(String, JobRepository) を使用

  ジョブリポジトリを設定する

  オーバーライド:

  クラス StepBuilderHelper<SimpleStepBuilder<I,O>> の repository 

  パラメーター:

  jobRepository - 設定するリポジトリ

  戻り値:

  これは流れるような連鎖を可能にする

• transactionManager

  public RemoteChunkingManagerStepBuilder<I,O> transactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  ステップに使用するトランザクションマネージャーを設定します。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の transactionManager 

  パラメーター:

  transactionManager - トランザクションマネージャー

  戻り値:

  流れるようなチェーン用

• listener

  public RemoteChunkingManagerStepBuilder<I,O> listener(ObjectSE listener)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  アノテーションベースのリスナー構成を使用してオブジェクトを登録します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の listener 

  パラメーター:

  listener - リスナーアノテーションで設定されたメソッドを持つオブジェクト

  戻り値:

  流れるようなチェーン用

• listener

  public RemoteChunkingManagerStepBuilder<I,O> listener(SkipListener<? super I,? super O> listener)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  スキップリスナーを登録します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の listener 

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• listener

  public RemoteChunkingManagerStepBuilder<I,O> listener(ChunkListener listener)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  チャンクリスナーを登録します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の listener 

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• transactionAttribute

  public RemoteChunkingManagerStepBuilder<I,O> transactionAttribute(org.springframework.transaction.interceptor.TransactionAttribute transactionAttribute)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  タスクレット実行のトランザクション属性を設定します。デフォルトはトランザクションマネージャーのデフォルト値ですが、たとえばより長いタイムアウトを提供するように操作できます。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の transactionAttribute 

  パラメーター:

  transactionAttribute - トランザクション属性セット

  戻り値:

  流れるようなチェーン用

• listener

  public RemoteChunkingManagerStepBuilder<I,O> listener(org.springframework.retry.RetryListener listener)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  再試行リスナーを登録します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の listener 

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• keyGenerator

  public RemoteChunkingManagerStepBuilder<I,O> keyGenerator(KeyGenerator keyGenerator)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  再試行されたアイテムを識別するためのキージェネレーターを設定します。トランザクションの境界を越えて再試行するには、アイテムが再び発生したときにアイテムを識別する必要があります。デフォルトの戦略では、アイテム自体を使用し、独自の実装に依存してアイテムを識別できるようにします。多くの場合、アイテムに信頼できるハッシュコードがあり、実装が等しい場合、リーダーがトランザクション対応ではなく（デフォルト）、アイテムプロセッサー自体がトランザクション対応ではない（デフォルトではない）か、新しいアイテムを作成しない限り、キージェネレーターは必要ありません。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の keyGenerator 

  パラメーター:

  keyGenerator - ステートフルな再試行のための鍵ジェネレーター

  戻り値:

  流れるようなチェーン用

• retryLimit

  public RemoteChunkingManagerStepBuilder<I,O> retryLimit(int retryLimit)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  失敗した項目を試行する最大回数。0 と 1 は両方とも、1 回だけ試行し、再試行しないように変換します。明示的な FaultTolerantStepBuilder.retryPolicy が設定されている場合は無視されます。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の retryLimit 

  パラメーター:

  retryLimit - 再試行制限 (デフォルトは 0)

  戻り値:

  流れるようなチェーン用

• retryPolicy

  public RemoteChunkingManagerStepBuilder<I,O> retryPolicy(org.springframework.retry.RetryPolicy retryPolicy)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  FaultTolerantStepBuilder.retryLimit(int) を使用する代わりに、明示的な再試行ポリシーと、他の場所で提供される再試行可能な例外を提供します。たとえば、異なる例外を異なる回数再試行するために使用できます。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の retryPolicy 

  パラメーター:

  retryPolicy - 再試行ポリシー

  戻り値:

  流れるようなチェーン用

• backOffPolicy

  public RemoteChunkingManagerStepBuilder<I,O> backOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  アイテムがすぐに再試行されるのを防ぐためのバックオフポリシーを提供します (たとえば、解決に時間がかかる可能性がある リモートリソース障害が原因で障害が発生した場合)。明示的な FaultTolerantStepBuilder.retryPolicy が設定されている場合は無視されます。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の backOffPolicy 

  パラメーター:

  backOffPolicy - 使用するバックオフポリシー (デフォルトではバックオフなし)

  戻り値:

  流れるようなチェーン用

• retryContextCache

  public RemoteChunkingManagerStepBuilder<I,O> retryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  明示的な再試行コンテキストキャッシュを提供します。アイテムの処理または書き込みで障害が発生した場合、再試行はトランザクション全体でステートフルであるため、後続の再試行のコンテキストに関するいくつかの情報を保存する必要があります。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の retryContextCache 

  パラメーター:

  retryContextCache - トランザクション間の再試行コンテキストのキャッシュ (デフォルトで標準のインメモリ実装に)

  戻り値:

  流れるようなチェーン用

• skipLimit

  public RemoteChunkingManagerStepBuilder<I,O> skipLimit(int skipLimit)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  ステップが失敗するまでにスキップする失敗した項目の最大数を設定します。デフォルト値は 10 です。

  この制限はデフォルトの LimitCheckingItemSkipPolicy を使用して適用されます。FaultTolerantStepBuilder.skipPolicy(SkipPolicy) を介してカスタム SkipPolicy が指定された場合、この制限はステップによって直接適用されませんが、カスタムポリシーによって適用されるように実装できます。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の skipLimit 

  パラメーター:

  skipLimit - スキップする失敗したアイテムの最大数。

  戻り値:

  これはスムーズな連鎖のためです。

  関連事項:

  • SkipPolicy

• noSkip

  public RemoteChunkingManagerStepBuilder<I,O> noSkip(ClassSE<? extends ThrowableSE> type)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  特定の例外（およびサブクラス）のスキップを明示的に防止します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の noSkip 

  パラメーター:

  type - スキップ不可の例外

  戻り値:

  流れるようなチェーン用

• skip

  public RemoteChunkingManagerStepBuilder<I,O> skip(ClassSE<? extends ThrowableSE> type)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  特定の例外（およびサブクラス）をスキップすることを明示的にリクエストします。これらの例外（およびそのサブクラス）は、チャンク処理（読み取り、処理、書き込み）の任意のフェーズ中にスローされる可能性がありますが、ステップ実行内の読み取り、処理、書き込みのスキップのカウントが個別に行われます。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の skip 

  パラメーター:

  type - 例外型。

  戻り値:

  流れるようなチェーン用

• skipPolicy

  public RemoteChunkingManagerStepBuilder<I,O> skipPolicy(SkipPolicy skipPolicy)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  スキップを管理するための明示的なポリシーを提供します。スキップポリシーは、スキップ可能な例外とその回数を決定します。

  カスタムポリシーを設定すると、FaultTolerantStepBuilder.skipLimit(int) で構成されたデフォルトの制限チェック動作が上書きされることに注意してください。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の skipPolicy 

  パラメーター:

  skipPolicy - スキップポリシー

  戻り値:

  流れるようなチェーン用

• noRollback

  public RemoteChunkingManagerStepBuilder<I,O> noRollback(ClassSE<? extends ThrowableSE> type)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  アイテムの読み取りまたは処理操作中に、この例外を無視できるものとしてマークします。追加のコールバックなしで処理が続行されます（通知が必要な場合は、代わりにスキップを使用してください）。ロールバックなしでスキップおよび再試行する保証がないため、書き込み中は無視されます。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の noRollback 

  パラメーター:

  type - ロールバックなしとしてマークする例外

  戻り値:

  流れるようなチェーン用

• noRetry

  public RemoteChunkingManagerStepBuilder<I,O> noRetry(ClassSE<? extends ThrowableSE> type)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  再試行から除外する例外（およびサブクラス）を明示的に要求します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の noRetry 

  パラメーター:

  type - 再試行から除外する例外

  戻り値:

  流れるようなチェーン用

• retry

  public RemoteChunkingManagerStepBuilder<I,O> retry(ClassSE<? extends ThrowableSE> type)

  クラスからコピーされた説明: FaultTolerantStepBuilder

  再試行する例外（およびサブクラス）を明示的に要求します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の retry 

  パラメーター:

  type - 再試行する例外

  戻り値:

  流れるようなチェーン用

• stream

  public RemoteChunkingManagerStepBuilder<I,O> stream(ItemStream stream)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  リスタートデータを管理するコールバックのストリームを登録します。

  オーバーライド:

  クラス FaultTolerantStepBuilder<I,O> の stream 

  パラメーター:

  stream - 登録するストリーム

  戻り値:

  流れるようなチェーン用

• chunk

  public RemoteChunkingManagerStepBuilder<I,O> chunk(int chunkSize)

  クラスからコピーされた説明: SimpleStepBuilder

  このステップのチャンクサイズまたはコミット間隔を設定します。これは、1 回のトランザクションで処理が開始される前に読み取られるアイテムの最大数です。SimpleStepBuilder.completionPolicy とは互換性がありません。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の chunk 

  パラメーター:

  chunkSize - チャンクサイズ (別名コミット間隔)

  戻り値:

  流れるようなチェーン用

• chunk

  public RemoteChunkingManagerStepBuilder<I,O> chunk(CompletionPolicy completionPolicy)

  クラスからコピーされた説明: SimpleStepBuilder

  チャンク処理の完了ポリシーを設定します。このポリシーがチャンクが完了したと判断するまでアイテムが読み取られ、chunk size（またはコミット間隔）だけの場合よりも詳細に制御されます。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の chunk 

  パラメーター:

  completionPolicy - チャンクの完了ポリシー

  戻り値:

  流れるようなチェーン用

• writer

  public RemoteChunkingManagerStepBuilder<I,O> writer(ItemWriter<? super O> writer) throws UnsupportedOperationExceptionSE

  このメソッドは UnsupportedOperationExceptionSE をスローします。これは、リモートチャンク設定のマネージャーステップのアイテムライターが自動的に ChunkMessageChannelItemWriter のインスタンスに設定されるためです。

  リモートチャンク用のマネージャーステップを構築する場合、項目ライターを提供する必要はありません。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の writer 

  パラメーター:

  writer - アイテムライター

  戻り値:

  流れるようなチェーン用

  例外:

  UnsupportedOperationExceptionSE - アイテムライターが提供されている場合

  関連事項:

  • ChunkMessageChannelItemWriter
  • RemoteChunkHandlerFactoryBean.setChunkWriter(ItemWriter)

• readerIsTransactionalQueue

  public RemoteChunkingManagerStepBuilder<I,O> readerIsTransactionalQueue()

  クラスからコピーされた説明: SimpleStepBuilder

  リーダーがトランザクション対応（通常はキュー）であることを示すフラグを設定します。つまり、失敗したアイテムはロールバックされ、後続のトランザクションで再表示される可能性があります。デフォルトは false です。つまり、アイテムはトランザクションの外部で読み取られ、場合によってはキャッシュされます。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の readerIsTransactionalQueue 

  戻り値:

  流れるようなチェーン用

• listener

  public RemoteChunkingManagerStepBuilder<I,O> listener(ItemReadListener<? super I> listener)

  クラスからコピーされた説明: SimpleStepBuilder

  アイテムリーダーリスナーを登録します。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の listener 

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• listener

  public RemoteChunkingManagerStepBuilder<I,O> listener(ItemWriteListener<? super O> listener)

  クラスからコピーされた説明: SimpleStepBuilder

  アイテムライターリスナーを登録します。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の listener 

  パラメーター:

  listener - 登録するリスナー

  戻り値:

  流れるようなチェーン用

• chunkOperations

  public RemoteChunkingManagerStepBuilder<I,O> chunkOperations(RepeatOperations repeatTemplate)

  クラスからコピーされた説明: SimpleStepBuilder

  chunk size または completion policy の代わりに、アイテムリーダーの繰り返しを処理する完全な繰り返し操作インスタンスを提供できます。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の chunkOperations 

  パラメーター:

  repeatTemplate - チャンクの完全な繰り返しテンプレート

  戻り値:

  流れるようなチェーン用

• exceptionHandler

  public RemoteChunkingManagerStepBuilder<I,O> exceptionHandler(ExceptionHandler exceptionHandler)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  タスクレットが失敗した場合に使用する例外ハンドラーを設定します。デフォルトではすべてを再スローします。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の exceptionHandler 

  パラメーター:

  exceptionHandler - 例外ハンドラー

  戻り値:

  流れるようなチェーン用

• stepOperations

  public RemoteChunkingManagerStepBuilder<I,O> stepOperations(RepeatOperations repeatTemplate)

  クラスからコピーされた説明: AbstractTaskletStepBuilder

  タスクレットの実行を繰り返すために使用する繰り返しテンプレートを設定します。デフォルトでは、タスクレットが FINISHED（または null）を返したときにのみ終了します。

  オーバーライド:

  クラス AbstractTaskletStepBuilder<SimpleStepBuilder<I,O>> の stepOperations 

  パラメーター:

  repeatTemplate - 反復のためのルールを持つ繰り返しテンプレート

  戻り値:

  流れるようなチェーン用

• startLimit

  public RemoteChunkingManagerStepBuilder<I,O> startLimit(int startLimit)

  オーバーライド:

  クラス StepBuilderHelper<SimpleStepBuilder<I,O>> の startLimit 

• listener

  public RemoteChunkingManagerStepBuilder<I,O> listener(StepExecutionListener listener)

  オーバーライド:

  クラス StepBuilderHelper<SimpleStepBuilder<I,O>> の listener 

• allowStartIfComplete

  public RemoteChunkingManagerStepBuilder<I,O> allowStartIfComplete(boolean allowStartIfComplete)

  オーバーライド:

  クラス StepBuilderHelper<SimpleStepBuilder<I,O>> の allowStartIfComplete 

• processor

  public RemoteChunkingManagerStepBuilder<I,O> processor(ItemProcessor<? super I,? extends O> itemProcessor)

  クラスからコピーされた説明: SimpleStepBuilder

  アイテムのストリームを処理または変換するアイテムプロセッサー。対応するインターフェースを実装している場合、AbstractTaskletStepBuilder.stream(ItemStream) またはリスナーとして自動的に登録されます。

  オーバーライド:

  クラス SimpleStepBuilder<I,O> の processor 

  パラメーター:

  itemProcessor - アイテムプロセッサー

  戻り値:

  流れるようなチェーン用