Class AbstractDdbCommand

    • Field Detail

      • 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)
      • addToResults

        protected void addToResults​(Map<String,​Object> map)
      • 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()