public class DynamoDbMetaDataStore
extends java.lang.Object
implements org.springframework.integration.metadata.ConcurrentMetadataStore, org.springframework.beans.factory.InitializingBean
ConcurrentMetadataStore for the AmazonDynamoDB.| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
DEFAULT_TABLE_NAME
The "SpringIntegrationMetadataStore" default name for the metadata table in the DynamoDB.
|
| Constructor and Description |
|---|
DynamoDbMetaDataStore(AmazonDynamoDBAsync dynamoDB) |
DynamoDbMetaDataStore(AmazonDynamoDBAsync dynamoDB,
java.lang.String tableName) |
| Modifier and Type | Method and Description |
|---|---|
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) |
boolean |
replace(java.lang.String key,
java.lang.String oldValue,
java.lang.String newValue) |
void |
setCreateTableDelay(int createTableDelay) |
void |
setCreateTableRetries(int createTableRetries) |
void |
setReadCapacity(long readCapacity) |
void |
setWriteCapacity(long writeCapacity) |
public static final java.lang.String DEFAULT_TABLE_NAME
public DynamoDbMetaDataStore(AmazonDynamoDBAsync dynamoDB)
public DynamoDbMetaDataStore(AmazonDynamoDBAsync dynamoDB, java.lang.String tableName)
public void setReadCapacity(long readCapacity)
public void setWriteCapacity(long writeCapacity)
public void setCreateTableRetries(int createTableRetries)
public void setCreateTableDelay(int createTableDelay)
public void afterPropertiesSet()
throws java.lang.Exception
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanjava.lang.Exceptionpublic 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 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 java.lang.String remove(java.lang.String key)
remove in interface org.springframework.integration.metadata.MetadataStore