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 |
setBillingMode(BillingMode billingMode) |
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 setCreateTableRetries(int createTableRetries)
public void setCreateTableDelay(int createTableDelay)
public void setBillingMode(BillingMode billingMode)
public void setReadCapacity(long readCapacity)
public void setWriteCapacity(long writeCapacity)
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