Class AbstractDdbCommand
- java.lang.Object
-
- org.apache.camel.component.aws2.ddb.AbstractDdbCommand
-
- Direct Known Subclasses:
BatchGetItemsCommand
,DeleteItemCommand
,DeleteTableCommand
,DescribeTableCommand
,GetItemCommand
,PutItemCommand
,QueryCommand
,ScanCommand
,UpdateItemCommand
,UpdateTableCommand
public abstract class AbstractDdbCommand extends Object
-
-
Field Summary
Fields Modifier and Type Field Description protected Ddb2Configuration
configuration
protected software.amazon.awssdk.services.dynamodb.DynamoDbClient
ddbClient
protected org.apache.camel.Exchange
exchange
-
Constructor Summary
Constructors Constructor Description AbstractDdbCommand(software.amazon.awssdk.services.dynamodb.DynamoDbClient ddbClient, Ddb2Configuration configuration, org.apache.camel.Exchange exchange)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
addAttributesToResult(Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> attributes)
protected void
addToResults(Map<Object,Object> map)
protected Collection<String>
determineAttributeNames()
protected Boolean
determineConsistentRead()
protected Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>
determineExclusiveStartKey()
protected Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>
determineItem()
protected Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue>
determineKey()
protected Integer
determineLimit()
protected String
determineReturnValues()
protected String
determineTableName()
protected Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue>
determineUpdateCondition()
abstract void
execute()
protected org.apache.camel.Message
getMessageForResponse(org.apache.camel.Exchange exchange)
-
-
-
Field Detail
-
configuration
protected Ddb2Configuration configuration
-
exchange
protected org.apache.camel.Exchange exchange
-
ddbClient
protected software.amazon.awssdk.services.dynamodb.DynamoDbClient ddbClient
-
-
Constructor Detail
-
AbstractDdbCommand
public AbstractDdbCommand(software.amazon.awssdk.services.dynamodb.DynamoDbClient ddbClient, Ddb2Configuration configuration, org.apache.camel.Exchange exchange)
-
-
Method Detail
-
execute
public abstract void execute()
-
getMessageForResponse
protected org.apache.camel.Message getMessageForResponse(org.apache.camel.Exchange exchange)
-
determineTableName
protected String determineTableName()
-
determineUpdateCondition
protected Map<String,software.amazon.awssdk.services.dynamodb.model.ExpectedAttributeValue> determineUpdateCondition()
-
determineItem
protected Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> determineItem()
-
determineReturnValues
protected String determineReturnValues()
-
addAttributesToResult
protected void addAttributesToResult(Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> attributes)
-
determineKey
protected Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> determineKey()
-
determineAttributeNames
protected Collection<String> determineAttributeNames()
-
determineConsistentRead
protected Boolean determineConsistentRead()
-
determineExclusiveStartKey
protected Map<String,software.amazon.awssdk.services.dynamodb.model.AttributeValue> determineExclusiveStartKey()
-
determineLimit
protected Integer determineLimit()
-
-