public class HazelcastMetadataStore
extends java.lang.Object
implements org.springframework.integration.metadata.ListenableMetadataStore, org.springframework.beans.factory.InitializingBean
IMap-based ListenableMetadataStore implementation.| Constructor and Description |
|---|
HazelcastMetadataStore(com.hazelcast.core.HazelcastInstance hazelcastInstance) |
HazelcastMetadataStore(com.hazelcast.map.IMap<java.lang.String,java.lang.String> map) |
| Modifier and Type | Method and Description |
|---|---|
void |
addListener(org.springframework.integration.metadata.MetadataStoreListener callback) |
void |
afterPropertiesSet() |
java.lang.String |
get(java.lang.String key) |
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) |
public HazelcastMetadataStore(com.hazelcast.core.HazelcastInstance hazelcastInstance)
public HazelcastMetadataStore(com.hazelcast.map.IMap<java.lang.String,java.lang.String> map)
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 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 void addListener(org.springframework.integration.metadata.MetadataStoreListener callback)
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 afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exception