public class PropertiesPersistingMetadataStore extends java.lang.Object implements ConcurrentMetadataStore, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean, java.io.Closeable, java.io.Flushable
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.Constructor and Description |
---|
PropertiesPersistingMetadataStore() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
void |
close() |
void |
destroy() |
void |
flush() |
java.lang.String |
get(java.lang.String key)
Reads a value for the given key from this MetadataStore.
|
void |
put(java.lang.String key,
java.lang.String value)
Writes a key value pair to this MetadataStore.
|
java.lang.String |
putIfAbsent(java.lang.String key,
java.lang.String value)
Atomically insert the key into the store.
|
java.lang.String |
remove(java.lang.String key)
Remove a value for the given key from this MetadataStore.
|
boolean |
replace(java.lang.String key,
java.lang.String oldValue,
java.lang.String newValue)
Atomically replace the value for the key in the store if the old
value matches the oldValue argument.
|
void |
setBaseDirectory(java.lang.String baseDirectory)
Set the location for the properties file.
|
void |
setFileName(java.lang.String fileName)
Set the name of the properties file in
setBaseDirectory(String) . |
public void setBaseDirectory(java.lang.String baseDirectory)
'java.io.tmpdir' + "/spring-integration/"
.baseDirectory
- the directory.public void setFileName(java.lang.String fileName)
setBaseDirectory(String)
.
Defaults to metadata-store.properties
,fileName
- the properties file name.public void afterPropertiesSet() throws java.lang.Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
java.lang.Exception
public void put(java.lang.String key, java.lang.String value)
MetadataStore
put
in interface MetadataStore
key
- The key.value
- The value.public java.lang.String get(java.lang.String key)
MetadataStore
get
in interface MetadataStore
key
- The key.public java.lang.String remove(java.lang.String key)
MetadataStore
remove
in interface MetadataStore
key
- The key.public java.lang.String putIfAbsent(java.lang.String key, java.lang.String value)
ConcurrentMetadataStore
putIfAbsent
in interface ConcurrentMetadataStore
key
- The key.value
- The value.public boolean replace(java.lang.String key, java.lang.String oldValue, java.lang.String newValue)
ConcurrentMetadataStore
replace
in interface ConcurrentMetadataStore
key
- The key.oldValue
- The old value.newValue
- The new value.public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public void flush()
flush
in interface java.io.Flushable
public void destroy() throws java.lang.Exception
destroy
in interface org.springframework.beans.factory.DisposableBean
java.lang.Exception