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 |
setTimeToLive(int timeToLive)
Configure a period in seconds for items expiration.
|
void |
setWriteCapacity(long writeCapacity) |
java.lang.String |
toString() |
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 setTimeToLive(int timeToLive)
<= 0), the TTL is disabled on the table.timeToLive - period in seconds for items expiration.public void afterPropertiesSet()
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanpublic 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.MetadataStorepublic java.lang.String toString()
toString in class java.lang.Object