パッケージ org.springframework.integration.zookeeper.metadata

クラス ZookeeperMetadataStore

java.lang.ObjectSE
org.springframework.integration.zookeeper.metadata.ZookeeperMetadataStore
実装されたすべてのインターフェース:
Lifecycle、Phased、SmartLifecycle、ConcurrentMetadataStore、ListenableMetadataStore、MetadataStore
public class ZookeeperMetadataStore extends ObjectSE implements ListenableMetadataStore, SmartLifecycle
Zookeeper ノードに基づく Zookeeper ベースの ListenableMetadataStore。値は子ノードに保存され、その名前はキーとして保存されます。
導入:
4.2
作成者:
Marius Bogoevici, Gary Russell, Artem Bilan, Christian Tzolov

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

    • ZookeeperMetadataStore

      public ZookeeperMetadataStore(org.apache.curator.framework.CuratorFramework client)

  • メソッドの詳細

    • setEncoding

      public void setEncoding(StringSE encoding)
      ZooKeeper にデータを格納するときに使用するエンコード
      パラメーター:
      encoding - テキストとしてエンコード

    • setRoot

      public void setRoot(StringSE root)
      ルートノード - ストアエントリはこのノードの子です。
      パラメーター:
      root - テキストとしてエンコード

    • getRoot

      public StringSE getRoot()

    • setAutoStartup

      public void setAutoStartup(boolean autoStartup)

    • setPhase

      public void setPhase(int phase)

    • putIfAbsent

      public StringSE putIfAbsent(StringSE key, StringSE value)
      インターフェースからコピーされた説明: ConcurrentMetadataStore
      キーをストアに原子的に挿入します。
      次で指定:
      インターフェース ConcurrentMetadataStore の putIfAbsent 
      パラメーター:
      key - キー。
      value - 値。
      戻り値:
      成功した場合は null、それ以外の場合は古い値。

    • replace

      public boolean replace(StringSE key, StringSE oldValue, StringSE newValue)
      インターフェースからコピーされた説明: ConcurrentMetadataStore
      古い値が oldValue 引数と一致する場合は、ストア内のキーの値を原子的に置き換えます。
      次で指定:
      インターフェース ConcurrentMetadataStore の replace 
      パラメーター:
      key - キー。
      oldValue - 古い値。
      newValue - 新しい値。
      戻り値:
      成功した場合は true。

    • addListener

      public void addListener(MetadataStoreListener listener)
      インターフェースからコピーされた説明: ListenableMetadataStore
      リスナーをメタデータストアに登録します。
      次で指定:
      インターフェース ListenableMetadataStore の addListener 
      パラメーター:
      listener - 登録するコールバック

    • removeListener

      public void removeListener(MetadataStoreListener callback)
      インターフェースからコピーされた説明: ListenableMetadataStore
      リスナーの登録を解除します。
      次で指定:
      インターフェース ListenableMetadataStore の removeListener 
      パラメーター:
      callback - 登録を解除するコールバック

    • put

      public void put(StringSE key, StringSE value)
      インターフェースからコピーされた説明: MetadataStore
      キーと値のペアをこの MetadataStore に書き込みます。
      次で指定:
      インターフェース MetadataStore の put 
      パラメーター:
      key - キー。
      value - 値。

    • get

      public StringSE get(StringSE key)
      インターフェースからコピーされた説明: MetadataStore
      この MetadataStore から指定されたキーの値を読み取ります。
      次で指定:
      インターフェース MetadataStore の get 
      パラメーター:
      key - キー。
      戻り値:
      値。

    • remove

      public StringSE remove(StringSE key)
      インターフェースからコピーされた説明: MetadataStore
      この MetadataStore から指定されたキーの値を削除します。
      次で指定:
      インターフェース MetadataStore の remove 
      パラメーター:
      key - キー。
      戻り値:
      キーに関連付けられた以前の値。キーのマッピングがなかった場合は null。

    • getPath

      public StringSE getPath(StringSE key)

    • isAutoStartup

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

    • start

      public void start()
      次で指定:
      インターフェース Lifecycle の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle の stop 

    • isRunning

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

    • getPhase

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