クラス MessageChannelPartitionHandler

メソッドの詳細

• afterPropertiesSet

  public void afterPropertiesSet() throws ExceptionSE

  次で指定:

  インターフェース org.springframework.beans.factory.InitializingBean の afterPropertiesSet 

  例外:

  ExceptionSE

• setTimeout

  public void setTimeout(long timeout)

  ジョブリポジトリのポーリングを使用する場合、待機する時間制限。

  パラメーター:

  timeout - 待機するミリ秒。デフォルトは -1（タイムアウトなし）です。

• setJobExplorer

  public void setJobExplorer(JobExplorer jobExplorer)

  ジョブリポジトリのクエリに使用する JobExplorer。ジョブリポジトリポーリングを使用する場合は、これまたは DataSourceSE のいずれかが必要です。

  パラメーター:

  jobExplorer - ルックアップに使用する JobExplorer

• setPollInterval

  public void setPollInterval(long pollInterval)

  ワーカーのステータスについてジョブリポジトリをポーリングする頻度。

  パラメーター:

  pollInterval - ポーリング間のミリ秒、デフォルトは 10000 (10 秒）。

• setDataSource

  public void setDataSource(DataSourceSE dataSource)

  ジョブリポジトリを指す DataSourceSE

  パラメーター:

  dataSource - ジョブリポジトリのストアを指す DataSourceSE

• setMessagingOperations

  public void setMessagingOperations(org.springframework.integration.core.MessagingTemplate messagingGateway)

  リモートワーカーとメッセージを送受信するための事前設定されたゲートウェイ。このプロパティを使用すると、送信のタイムアウトやその他のプロパティを大幅に制御できます。内部でチャネルを設定する必要があります。

  • StepExecutionRequest ペイロードを受け入れることができるリクエストチャネル
  • StepExecution 結果のリストを返す返信チャネル

  応答のタイムアウトは、リモートステップが完了するのに十分な時間設定する必要があります。

  パラメーター:

  messagingGateway - 設定する MessagingTemplate 

• setStepName

  public void setStepName(StringSE stepName)

  パーティション化された StepExecution を実行するために使用される Step の名前。これは通常の Spring Batch ステップであり、StepExecution コンテキストの入力パラメーターに基づいて実行を完了するために必要なすべてのビジネスロジックが含まれています。名前は、リモートワーカーによって Step インスタンスに変換されます。

  パラメーター:

  stepName - ビジネスロジックを実行する Step インスタンスの名前

• aggregate

  @Aggregator(sendPartialResultsOnExpiry="true") public ListSE<?> aggregate(@Payloads ListSE<?> messages)

  パラメーター:

  messages - 集約されるメッセージ

  戻り値:

  渡されたリスト

• setReplyChannel

  public void setReplyChannel(org.springframework.messaging.PollableChannel replyChannel)

• doHandle

  protected SetSE<StepExecution> doHandle(StepExecution managerStepExecution, SetSE<StepExecution> partitionStepExecutions) throws ExceptionSE

  StepExecutionRequest オブジェクトを MessagingTemplate のリクエストチャネルに送信し、その結果を応答チャネルで StepExecution のリストとして受信します。個々のリモート応答のアグリゲーターとして aggregate(List) メソッドを使用します。すべての作業が行われる可能性が高くなるように、受信タイムアウトは MessagingTemplate と アグリゲーターで現実的に設定する必要があります。

  次で指定:

  クラス AbstractPartitionHandler の doHandle 

  パラメーター:

  managerStepExecution - パーティション全体の実行

  partitionStepExecutions - 実行する StepExecution インスタンス

  戻り値:

  これらの完成した StepExecution インスタンスの更新されたビュー

  例外:

  ExceptionSE - 何かがうまくいかない場合。これにより、実装は自由になり、必要に応じて呼び出し元が例外をステップ障害に変換することに依存することができます。

  関連事項:

  • PartitionHandler.handle(StepExecutionSplitter, StepExecution)