Package org.springframework.integration.gemfire.metadata

Class GemfireMetadataStore

java.lang.Object

org.springframework.integration.gemfire.metadata.GemfireMetadataStore

All Implemented Interfaces:

ConcurrentMetadataStore, ListenableMetadataStore, MetadataStore

public class GemfireMetadataStore
extends Object
implements ListenableMetadataStore

Gemfire implementation of ListenableMetadataStore. Use this MetadataStore to achieve meta-data persistence shared across application instances and restarts.

Since:

4.0

Author:

Artem Bilan, Venil Noronha, Gary Russell

Field Summary

Fields

Modifier and Type	Field	Description
static final String	KEY

Constructor Summary

Constructors

Constructor	Description
GemfireMetadataStore(org.apache.geode.cache.Cache cache)
GemfireMetadataStore(org.apache.geode.cache.Region<String,String> region)

Method Summary

Modifier and Type	Method	Description
void	addListener(MetadataStoreListener listener)	Register a listener with the metadata store.
String	get(String key)	Reads a value for the given key from this MetadataStore.
void	put(String key, String value)	Writes a key value pair to this MetadataStore.
String	putIfAbsent(String key, String value)	Atomically insert the key into the store.
String	remove(String key)	Remove a value for the given key from this MetadataStore.
void	removeListener(MetadataStoreListener listener)	Unregister a listener.
boolean	replace(String key, String oldValue, String newValue)	Atomically replace the value for the key in the store if the old value matches the oldValue argument.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

KEY

public static final String KEY

See Also:

• Constant Field Values

Constructor Details

GemfireMetadataStore

public GemfireMetadataStore(org.apache.geode.cache.Cache cache)

GemfireMetadataStore

public GemfireMetadataStore(org.apache.geode.cache.Region<String,String> region)

Method Details

put

public void put(String key,
 String value)

Description copied from interface: MetadataStore

Writes a key value pair to this MetadataStore.

Specified by:

put in interface MetadataStore

Parameters:

key - The key.

value - The value.

putIfAbsent

public String putIfAbsent(String key,
 String value)

Description copied from interface: ConcurrentMetadataStore

Atomically insert the key into the store.

Specified by:

putIfAbsent in interface ConcurrentMetadataStore

Parameters:

key - The key.

value - The value.

Returns:

null if successful, the old value otherwise.

replace

public boolean replace(String key,
 String oldValue,
 String newValue)

Description copied from interface: ConcurrentMetadataStore

Atomically replace the value for the key in the store if the old value matches the oldValue argument.

Specified by:

replace in interface ConcurrentMetadataStore

Parameters:

key - The key.

oldValue - The old value.

newValue - The new value.

Returns:

true if successful.

get

public String get(String key)

Description copied from interface: MetadataStore

Reads a value for the given key from this MetadataStore.

Specified by:

get in interface MetadataStore

Parameters:

key - The key.

Returns:

The value.

remove

public String remove(String key)

Description copied from interface: MetadataStore

Remove a value for the given key from this MetadataStore.

Specified by:

remove in interface MetadataStore

Parameters:

key - The key.

Returns:

The previous value associated with key, or null if there was no mapping for key.

addListener

public void addListener(MetadataStoreListener listener)

Description copied from interface: ListenableMetadataStore

Register a listener with the metadata store.

Specified by:

addListener in interface ListenableMetadataStore

Parameters:

listener - the callback to be registered

removeListener

public void removeListener(MetadataStoreListener listener)

Description copied from interface: ListenableMetadataStore

Unregister a listener.

Specified by:

removeListener in interface ListenableMetadataStore

Parameters:

listener - the callback to be unregistered