クラス RemoteStep

java.lang.ObjectSE
org.springframework.batch.core.step.AbstractStep
org.springframework.batch.integration.remote.RemoteStep
実装済みのインターフェース一覧:
Step, StoppableStep, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean

public class RemoteStep extends AbstractStep
メッセージングを通じて リモートワーカーステップに実行を委譲する Step 実装。

リモートワーカーステップは、ステップ実行リクエストを受信するために、同じメッセージチャネルをリッスンしている必要があります。

ステップ実行はローカルで作成され、リモートワーカーステップに送信され、ジョブリポジトリ内のステータスとコンテキストが更新されます。RemoteStep はジョブリポジトリをポーリングしてステップの完了を確認します。

導入:
6.0.0
作成者:
Mahmoud Ben Hassine
  • コンストラクターの詳細

    • RemoteStep

      public RemoteStep(StringSE name, StringSE remoteStepName, JobRepository jobRepository, org.springframework.integration.core.MessagingTemplate messagingTemplate)
      新しい RemoteStep インスタンスを作成します。
      パラメーター:
      name - このステップの名前
      remoteStepName - 実行するリモートワーカーステップの名前
      jobRepository - 使用するジョブリポジトリ
      messagingTemplate - ステップ実行リクエストを送信するために使用するメッセージングテンプレート
  • メソッドの詳細

    • setTimeout

      public void setTimeout(long timeout)
    • setPollInterval

      public void setPollInterval(long pollInterval)
    • setMessageChannel

      public void setMessageChannel(org.springframework.messaging.MessageChannel messageChannel)
    • doExecute

      protected void doExecute(StepExecution stepExecution) throws ExceptionSE
      クラスからコピーされた説明: AbstractStep
      ビジネスロジックを実行するサブクラスの拡張ポイント。サブクラスは、戻る前に StepExecutionExitStatus を設定する必要があります。
      次で指定:
      クラス AbstractStepdoExecute 
      パラメーター:
      stepExecution - 現在のステップのコンテキスト
      例外:
      ExceptionSE - 実装によってスローされたチェック済み例外