org.apache.camel.component.aws.ddb
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

protected DdbConfiguration	configuration
protected com.amazonaws.services.dynamodb.AmazonDynamoDB	ddbClient
protected org.apache.camel.Exchange	exchange

Constructor Summary

AbstractDdbCommand(com.amazonaws.services.dynamodb.AmazonDynamoDB ddbClient, DdbConfiguration configuration, org.apache.camel.Exchange exchange)

Method Summary

protected void	addAttributesToResult(Map<String,com.amazonaws.services.dynamodb.model.AttributeValue> attributes)
protected void	addToResult(String headerKey, Object value)
protected Collection<String>	determineAttributeNames()
protected Boolean	determineConsistentRead()
protected Map<String,com.amazonaws.services.dynamodb.model.AttributeValue>	determineItem()
protected com.amazonaws.services.dynamodb.model.Key	determineKey()
protected String	determineReturnValues()
protected String	determineTableName()
protected Map<String,com.amazonaws.services.dynamodb.model.ExpectedAttributeValue>	determineUpdateCondition()
abstract void	execute()
protected org.apache.camel.Message	getMessageForResponse(org.apache.camel.Exchange exchange)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

configuration

protected DdbConfiguration configuration

exchange

protected org.apache.camel.Exchange exchange

ddbClient

protected com.amazonaws.services.dynamodb.AmazonDynamoDB ddbClient

Constructor Detail

AbstractDdbCommand

public AbstractDdbCommand(com.amazonaws.services.dynamodb.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.dynamodb.model.ExpectedAttributeValue> determineUpdateCondition()

determineItem

protected Map<String,com.amazonaws.services.dynamodb.model.AttributeValue> determineItem()

determineReturnValues

protected String determineReturnValues()

addAttributesToResult

protected void addAttributesToResult(Map<String,com.amazonaws.services.dynamodb.model.AttributeValue> attributes)

addToResult

protected void addToResult(String headerKey,
                           Object value)

determineKey

protected com.amazonaws.services.dynamodb.model.Key determineKey()

determineAttributeNames

protected Collection<String> determineAttributeNames()

determineConsistentRead

protected Boolean determineConsistentRead()