コンストラクターの詳細

• MessageChannelPartitionHandler

  public MessageChannelPartitionHandler()

メソッドの詳細

• afterPropertiesSet

  public void afterPropertiesSet()
                          throws java.lang.Exception

  次で指定:

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

  例外:

  java.lang.Exception

• setTimeout

  public void setTimeout(long timeout)

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

  パラメーター:

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

• setJobExplorer

  public void setJobExplorer(JobExplorer jobExplorer)

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

  パラメーター:

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

• setPollInterval

  public void setPollInterval(long pollInterval)

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

  パラメーター:

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

• setDataSource

  public void setDataSource(javax.sql.DataSource dataSource)

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

  パラメーター:

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

• setMessagingOperations

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

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

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

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

  パラメーター:

  messagingGateway - 設定する MessagingTemplate 

• setGridSize

  public void setGridSize(int gridSize)

  handle(StepExecutionSplitter, StepExecution) メソッドで StepExecutionSplitter に渡され、理想的には必要な StepExecution インスタンスの数を指示します。StepExecutionSplitter は、入力データパーティションを保持する必要があるため、再起動の場合にグリッドサイズを無視できます。

  パラメーター:

  gridSize - 作成されるステップ実行の数

• setStepName

  public void setStepName(java.lang.String stepName)

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

  パラメーター:

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

• aggregate

  @Aggregator(sendPartialResultsOnExpiry="true")
  public java.util.List<?> aggregate(@Payloads
                                                                                    java.util.List<?> messages)

  パラメーター:

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

  戻り値:

  渡されたリスト

• setReplyChannel

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

• handle

  public java.util.Collection<StepExecution> handle(StepExecutionSplitter stepExecutionSplitter,
                                                    StepExecution masterStepExecution)
                                             throws java.lang.Exception

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

  次で指定:

  インターフェース PartitionHandler の handle 

  パラメーター:

  stepExecutionSplitter - StepExecution インスタンスのコレクションを生成するための戦略

  masterStepExecution - パーティション全体のマスターステップの実行

  戻り値:

  完成した StepExecution インスタンスのコレクション

  例外:

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

  関連事項:

  PartitionHandler.handle(StepExecutionSplitter, StepExecution)