クラス LeaderInitiator

java.lang.ObjectSE
org.springframework.integration.zookeeper.leader.LeaderInitiator
実装されたすべてのインターフェース:
Lifecycle、Phased、SmartLifecycle
public class LeaderInitiator extends ObjectSE implements SmartLifecycle
ZooKeeper/Curator を使用したブートストラップリーダーシップ candidates。構築時に、start() を呼び出して、リーダー選出の候補者を登録する必要があります。
導入:
4.2
作成者:
Patrick Peralta, Janne Valkealahti, Gary Russell, Artem Bilan, Ivan Zaitsev, Christian Tzolov

  • コンストラクターの詳細

    • LeaderInitiator

      public LeaderInitiator(org.apache.curator.framework.CuratorFramework client, Candidate candidate)
      LeaderInitiator を作成します。
      パラメーター:
      client - キュレータークライアント
      candidate - リーダー選出候補

    • LeaderInitiator

      public LeaderInitiator(org.apache.curator.framework.CuratorFramework client, Candidate candidate, StringSE namespace)
      LeaderInitiator を作成します。
      パラメーター:
      client - キュレータークライアント
      candidate - リーダー選出候補
      namespace - ZooKeeper の名前空間ベースパス

  • メソッドの詳細

    • isRunning

      public boolean isRunning()
      次で指定:
      インターフェース Lifecycle の isRunning 
      戻り値:
      この candidate のリーダー選出が実行されている場合は true

    • getPhase

      public int getPhase()
      次で指定:
      インターフェース Phased の getPhase 
      次で指定:
      インターフェース SmartLifecycle の getPhase 

    • setPhase

      public void setPhase(int phase)
      パラメーター:
      phase - フェーズ
      関連事項:

    • isAutoStartup

      public boolean isAutoStartup()
      次で指定:
      インターフェース SmartLifecycle の isAutoStartup 

    • setAutoStartup

      public void setAutoStartup(boolean autoStartup)
      パラメーター:
      autoStartup - 自動的に開始する場合は true
      関連事項:

    • start

      public void start()
      リーダー選出のための candidate の登録を開始します。
      次で指定:
      インターフェース Lifecycle の start 

    • stop

      public void stop()
      リーダー選出のための candidate の登録を停止します。候補者が現在リーダーである場合、そのリーダーシップは取り消されます。
      次で指定:
      インターフェース Lifecycle の stop 

    • setLeaderEventPublisher

      public void setLeaderEventPublisher(LeaderEventPublisher leaderEventPublisher)
      LeaderEventPublisher を設定します。
      パラメーター:
      leaderEventPublisher - イベント発行者

    • getContext

      public LeaderInitiator.CuratorContext getContext()
      イニシエーターのコンテキスト。
      戻り値:
      コンテキスト。
      導入:
      5.0