Class DynamoDbMetadataStore
java.lang.Object
org.springframework.integration.aws.metadata.DynamoDbMetadataStore
- All Implemented Interfaces:
org.springframework.beans.factory.InitializingBean,org.springframework.integration.metadata.ConcurrentMetadataStore,org.springframework.integration.metadata.MetadataStore
public class DynamoDbMetadataStore
extends Object
implements org.springframework.integration.metadata.ConcurrentMetadataStore, org.springframework.beans.factory.InitializingBean
The
ConcurrentMetadataStore for the AmazonDynamoDB.- Since:
- 1.1
- Author:
- Artem Bilan, Asiel Caballero
-
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final StringThe "SpringIntegrationMetadataStore" default name for the metadata table in the DynamoDB. -
Constructor Summary
ConstructorsConstructorDescriptionDynamoDbMetadataStore(AmazonDynamoDBAsync dynamoDB) DynamoDbMetadataStore(AmazonDynamoDBAsync dynamoDB, String tableName) -
Method Summary
Modifier and TypeMethodDescriptionvoidvoidputIfAbsent(String key, String value) booleanvoidsetBillingMode(BillingMode billingMode) voidsetCreateTableDelay(int createTableDelay) voidsetCreateTableRetries(int createTableRetries) voidsetReadCapacity(long readCapacity) voidsetTimeToLive(int timeToLive) Configure a period in seconds for items expiration.voidsetWriteCapacity(long writeCapacity) toString()
-
Field Details
-
DEFAULT_TABLE_NAME
The "SpringIntegrationMetadataStore" default name for the metadata table in the DynamoDB.- See Also:
-
-
Constructor Details
-
DynamoDbMetadataStore
-
DynamoDbMetadataStore
-
-
Method Details
-
setCreateTableRetries
public void setCreateTableRetries(int createTableRetries) -
setCreateTableDelay
public void setCreateTableDelay(int createTableDelay) -
setBillingMode
-
setReadCapacity
public void setReadCapacity(long readCapacity) -
setWriteCapacity
public void setWriteCapacity(long writeCapacity) -
setTimeToLive
public void setTimeToLive(int timeToLive) Configure a period in seconds for items expiration. If it is configured to non-positive value (<= 0), the TTL is disabled on the table.- Parameters:
timeToLive- period in seconds for items expiration.- Since:
- 2.0
- See Also:
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceorg.springframework.beans.factory.InitializingBean
-
put
- Specified by:
putin interfaceorg.springframework.integration.metadata.MetadataStore
-
get
- Specified by:
getin interfaceorg.springframework.integration.metadata.MetadataStore
-
putIfAbsent
- Specified by:
putIfAbsentin interfaceorg.springframework.integration.metadata.ConcurrentMetadataStore
-
replace
- Specified by:
replacein interfaceorg.springframework.integration.metadata.ConcurrentMetadataStore
-
remove
- Specified by:
removein interfaceorg.springframework.integration.metadata.MetadataStore
-
toString
-