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(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB) |
DynamoDbMetaDataStore(com.amazonaws.services.dynamodbv2.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(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)
public DynamoDbMetaDataStore(com.amazonaws.services.dynamodbv2.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