public class ZookeeperMetadataStore
extends java.lang.Object
implements org.springframework.integration.metadata.ListenableMetadataStore, org.springframework.context.SmartLifecycle
ListenableMetadataStore based on a Zookeeper node.
Values are stored in the children node, the names of which are stored as keys.| Constructor and Description |
|---|
ZookeeperMetadataStore(org.apache.curator.framework.CuratorFramework client) |
| Modifier and Type | Method and Description |
|---|---|
void |
addListener(org.springframework.integration.metadata.MetadataStoreListener listener) |
java.lang.String |
get(java.lang.String key) |
java.lang.String |
getPath(java.lang.String key) |
int |
getPhase() |
java.lang.String |
getRoot() |
boolean |
isAutoStartup() |
boolean |
isRunning() |
void |
put(java.lang.String key,
java.lang.String value) |
java.lang.String |
putIfAbsent(java.lang.String key,
java.lang.String value) |
java.lang.String |
remove(java.lang.String key) |
void |
removeListener(org.springframework.integration.metadata.MetadataStoreListener callback) |
boolean |
replace(java.lang.String key,
java.lang.String oldValue,
java.lang.String newValue) |
void |
setAutoStartup(boolean autoStartup) |
void |
setEncoding(java.lang.String encoding)
Encoding to use when storing data in ZooKeeper
|
void |
setPhase(int phase) |
void |
setRoot(java.lang.String root)
Root node - store entries are children of this node.
|
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
public ZookeeperMetadataStore(org.apache.curator.framework.CuratorFramework client)
public void setEncoding(java.lang.String encoding)
encoding - encoding as textpublic void setRoot(java.lang.String root)
root - encoding as textpublic java.lang.String getRoot()
public void setAutoStartup(boolean autoStartup)
public void setPhase(int phase)
public java.lang.String putIfAbsent(java.lang.String key,
java.lang.String value)
putIfAbsent in interface org.springframework.integration.metadata.ConcurrentMetadataStorepublic boolean replace(java.lang.String key,
java.lang.String oldValue,
java.lang.String newValue)
replace in interface org.springframework.integration.metadata.ConcurrentMetadataStorepublic void addListener(org.springframework.integration.metadata.MetadataStoreListener listener)
addListener in interface org.springframework.integration.metadata.ListenableMetadataStorepublic void removeListener(org.springframework.integration.metadata.MetadataStoreListener callback)
removeListener in interface org.springframework.integration.metadata.ListenableMetadataStorepublic void put(java.lang.String key,
java.lang.String value)
put in interface org.springframework.integration.metadata.MetadataStorepublic java.lang.String get(java.lang.String key)
get in interface org.springframework.integration.metadata.MetadataStorepublic java.lang.String remove(java.lang.String key)
remove in interface org.springframework.integration.metadata.MetadataStorepublic java.lang.String getPath(java.lang.String key)
public boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecyclepublic int getPhase()
getPhase in interface org.springframework.context.PhasedgetPhase in interface org.springframework.context.SmartLifecycle