Package org.springframework.integration.metadata

Class PropertiesPersistingMetadataStore

java.lang.Object

org.springframework.integration.metadata.PropertiesPersistingMetadataStore

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, DisposableBean, InitializingBean, ConcurrentMetadataStore, MetadataStore

public class PropertiesPersistingMetadataStore
extends Object
implements ConcurrentMetadataStore, InitializingBean, DisposableBean, Closeable, Flushable

Properties file-based implementation of MetadataStore. To avoid conflicts each instance should be constructed with the unique key from which unique file name will be generated. By default, the properties file will be 'java.io.tmpdir' + "/spring-integration/metadata-store.properties", but the directory and filename are settable.

Since:

2.0

Author:

Oleg Zhurakousky, Mark Fisher, Gary Russell

Constructor Summary

Constructors

Constructor	Description
PropertiesPersistingMetadataStore()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
void	close()
void	destroy()
void	flush()
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.
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.
void	setBaseDirectory(String baseDirectory)	Set the location for the properties file.
void	setFileName(String fileName)	Set the name of the properties file in setBaseDirectory(String).

Methods inherited from class java.lang.Object

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

Constructor Details

PropertiesPersistingMetadataStore

public PropertiesPersistingMetadataStore()

Method Details

setBaseDirectory

public void setBaseDirectory(String baseDirectory)

Set the location for the properties file. Defaults to 'java.io.tmpdir' + "/spring-integration/".

Parameters:

baseDirectory - the directory.

setFileName

public void setFileName(String fileName)

Set the name of the properties file in setBaseDirectory(String). Defaults to metadata-store.properties,

Parameters:

fileName - the properties file name.

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

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.

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.

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.

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

flush

public void flush()

Specified by:

flush in interface Flushable

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean