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.InitializingBean
java.lang.Exception
public void put(java.lang.String key, java.lang.String value)
put
in interface org.springframework.integration.metadata.MetadataStore
public java.lang.String get(java.lang.String key)
get
in interface org.springframework.integration.metadata.MetadataStore
public java.lang.String putIfAbsent(java.lang.String key, java.lang.String value)
putIfAbsent
in interface org.springframework.integration.metadata.ConcurrentMetadataStore
public boolean replace(java.lang.String key, java.lang.String oldValue, java.lang.String newValue)
replace
in interface org.springframework.integration.metadata.ConcurrentMetadataStore
public java.lang.String remove(java.lang.String key)
remove
in interface org.springframework.integration.metadata.MetadataStore