Class AbstractDdbCommand
- java.lang.Object
-
- org.apache.camel.component.aws.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 DdbConfiguration
configuration
protected com.amazonaws.services.dynamodbv2.AmazonDynamoDB
ddbClient
protected org.apache.camel.Exchange
exchange
-
Constructor Summary
Constructors Constructor Description AbstractDdbCommand(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddbClient, DdbConfiguration 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,com.amazonaws.services.dynamodbv2.model.AttributeValue> attributes)
protected void
addToResults(Map<String,Object> map)
protected Collection<String>
determineAttributeNames()
protected Boolean
determineConsistentRead()
protected Map<String,com.amazonaws.services.dynamodbv2.model.AttributeValue>
determineExclusiveStartKey()
protected Map<String,com.amazonaws.services.dynamodbv2.model.AttributeValue>
determineItem()
protected Map<String,com.amazonaws.services.dynamodbv2.model.AttributeValue>
determineKey()
protected Integer
determineLimit()
protected String
determineReturnValues()
protected String
determineTableName()
protected Map<String,com.amazonaws.services.dynamodbv2.model.ExpectedAttributeValue>
determineUpdateCondition()
abstract void
execute()
protected org.apache.camel.Message
getMessageForResponse(org.apache.camel.Exchange exchange)
-
-
-
Field Detail
-
configuration
protected DdbConfiguration configuration
-
exchange
protected org.apache.camel.Exchange exchange
-
ddbClient
protected com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddbClient
-
-
Constructor Detail
-
AbstractDdbCommand
public AbstractDdbCommand(com.amazonaws.services.dynamodbv2.AmazonDynamoDB ddbClient, DdbConfiguration 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,com.amazonaws.services.dynamodbv2.model.ExpectedAttributeValue> determineUpdateCondition()
-
determineItem
protected Map<String,com.amazonaws.services.dynamodbv2.model.AttributeValue> determineItem()
-
determineReturnValues
protected String determineReturnValues()
-
addAttributesToResult
protected void addAttributesToResult(Map<String,com.amazonaws.services.dynamodbv2.model.AttributeValue> attributes)
-
determineKey
protected Map<String,com.amazonaws.services.dynamodbv2.model.AttributeValue> determineKey()
-
determineAttributeNames
protected Collection<String> determineAttributeNames()
-
determineConsistentRead
protected Boolean determineConsistentRead()
-
determineExclusiveStartKey
protected Map<String,com.amazonaws.services.dynamodbv2.model.AttributeValue> determineExclusiveStartKey()
-
determineLimit
protected Integer determineLimit()
-
-