コンストラクターの詳細

• ChunkMessageChannelItemWriter

  public ChunkMessageChannelItemWriter()

メソッドの詳細

• setMaxWaitTimeouts

  public void setMaxWaitTimeouts(int maxWaitTimeouts)

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

  パラメーター:

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

• setThrottleLimit

  public void setThrottleLimit(long throttleLimit)

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

  パラメーター:

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

• setMessagingOperations

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

• setReplyChannel

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

• write

  public void write(java.util.List<? extends T> items)
             throws java.lang.Exception

  インターフェースからコピーされた説明: ItemWriter
  指定されたデータ要素を処理します。通常の操作では null アイテムで呼び出されません。

  次で指定:

  インターフェース ItemWriter<T> の write 

  パラメーター:

  items - 書かれる項目

  例外:

  java.lang.Exception - エラーがある場合。フレームワークは例外をキャッチし、必要に応じて変換または再スローします。

• beforeStep

  public void beforeStep(StepExecution stepExecution)

  インターフェースからコピーされた説明: StepExecutionListener
  現在のスコープの StepExecution を使用して、リスナーの状態を初期化します。

  次で指定:

  インターフェース StepExecutionListener の beforeStep 

  オーバーライド:

  クラス StepExecutionListenerSupport の beforeStep 

  パラメーター:

  stepExecution - StepExecution のインスタンス。

• afterStep

  @Nullable
  public ExitStatus afterStep(StepExecution stepExecution)

  インターフェースからコピーされた説明: StepExecutionListener
  リスナーにステップの終了ステータスを変更する機会を与えます。返される値は、ExitStatus.and(ExitStatus) を使用して通常の終了ステータスと結合されます。ステップの処理ロジックの実行後に呼び出されます（成功または失敗の両方）。このメソッドで例外をスローしても効果はなく、ログに記録されるだけです。

  次で指定:

  インターフェース StepExecutionListener の afterStep 

  オーバーライド:

  クラス StepExecutionListenerSupport の afterStep 

  パラメーター:

  stepExecution - StepExecution インスタンス。

  戻り値:

  通常値と組み合わせる ExitStatus。null を返し、古い値を変更せずに残します。

• close

  public void close()
             throws ItemStreamException

  インターフェースからコピーされた説明: ItemStream
  ストリームの動作にリソースが必要な場合、ここで破棄する必要があります。このメソッドが呼び出されると、他のすべてのメソッド（open を除く）は例外をスローする場合があります。

  次で指定:

  インターフェース ItemStream の close 

  例外:

  ItemStreamException

• open

  public void open(ExecutionContext executionContext)
            throws ItemStreamException

  インターフェースからコピーされた説明: ItemStream
  提供された ExecutionContext のストリームを開きます。

  次で指定:

  インターフェース ItemStream の open 

  パラメーター:

  executionContext - 現在のステップの ExecutionContext 再起動時のステップの最後の実行からの executionContext になります。

  例外:

  ItemStreamException

• update

  public void update(ExecutionContext executionContext)
              throws ItemStreamException

  インターフェースからコピーされた説明: ItemStream
  オープン中に提供された実行コンテキストが保存されようとしていることを示します。状態が残っているが、コンテキストに入れられていない場合は、ここに追加する必要があります。

  次で指定:

  インターフェース ItemStream の update 

  パラメーター:

  executionContext - 更新される

  例外:

  ItemStreamException

• getStepContributions

  public java.util.Collection<StepContribution> getStepContributions()

  インターフェースからコピーされた説明: StepContributionSource
  現在利用可能なコントリビューションを取得し、ソースをドレインします。新しいコントリビュートが到着しない限り、次の呼び出しは空のコレクションを返します。

  次で指定:

  インターフェース StepContributionSource の getStepContributions 

  戻り値:

  StepContribution インスタンスのコレクション