org.apache.camel.component.aws.ddbstream

Class DdbStreamEndpoint

java.lang.Object

org.apache.camel.support.ServiceSupport

org.apache.camel.impl.DefaultEndpoint

org.apache.camel.impl.ScheduledPollEndpoint

org.apache.camel.component.aws.ddbstream.DdbStreamEndpoint

All Implemented Interfaces:

org.apache.camel.CamelContextAware, org.apache.camel.Endpoint, org.apache.camel.IsSingleton, org.apache.camel.Service, org.apache.camel.ShutdownableService, org.apache.camel.spi.HasId, org.apache.camel.StatefulService, org.apache.camel.SuspendableService

@UriEndpoint(firstVersion="2.17.0",
             scheme="aws-ddbstream",
             title="AWS DynamoDB Streams",
             consumerOnly=true,
             syntax="aws-ddbstream:tableName",
             consumerClass=DdbStreamConsumer.class,
             label="cloud,messaging,streams")
public class DdbStreamEndpoint
extends org.apache.camel.impl.ScheduledPollEndpoint

The aws-ddbstream component is used for working with Amazon DynamoDB Streams.

Field Summary

Fields inherited from class org.apache.camel.support.ServiceSupport

shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending

Constructor Summary

Constructors

Constructor and Description
DdbStreamEndpoint(String uri, String tableName, DdbStreamComponent component)

Method Summary

Modifier and Type	Method and Description
org.apache.camel.Consumer	createConsumer(org.apache.camel.Processor processor)
org.apache.camel.Producer	createProducer()
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams	getAmazonDynamoDBStreamsClient()
com.amazonaws.services.dynamodbv2.model.ShardIteratorType	getIteratorType()
int	getMaxResultsPerRequest()
String	getSequenceNumber()
SequenceNumberProvider	getSequenceNumberProvider()
String	getTableName()
boolean	isSingleton()
void	setAmazonDynamoDbStreamsClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams amazonDynamoDbStreamsClient)
void	setIteratorType(com.amazonaws.services.dynamodbv2.model.ShardIteratorType iteratorType)
void	setMaxResultsPerRequest(int maxResultsPerRequest)
void	setSequenceNumberProvider(SequenceNumberProvider sequenceNumberProvider)
void	setTableName(String tableName)
String	toString()

Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint

configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, doStart, doStop, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, initConsumerProperties, isGreedy, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay

Methods inherited from class org.apache.camel.impl.DefaultEndpoint

configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExceptionHandler, getExchangePattern, getId, getPollingConsumerBlockTimeout, getPollingConsumerQueueSize, hashCode, isBridgeErrorHandler, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setBridgeErrorHandler, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExceptionHandler, setExchangePattern, setPollingConsumerBlockTimeout, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous

Methods inherited from class org.apache.camel.support.ServiceSupport

doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.camel.Service

start, stop

Constructor Detail

DdbStreamEndpoint

public DdbStreamEndpoint(String uri,
                         String tableName,
                         DdbStreamComponent component)

Method Detail

createProducer

public org.apache.camel.Producer createProducer()
                                         throws Exception

Throws:

Exception

createConsumer

public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor)
                                         throws Exception

Throws:

Exception

isSingleton

public boolean isSingleton()

getSequenceNumber

public String getSequenceNumber()

toString

public String toString()

Overrides:

toString in class org.apache.camel.impl.DefaultEndpoint

getAmazonDynamoDBStreamsClient

public com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams getAmazonDynamoDBStreamsClient()

setAmazonDynamoDbStreamsClient

public void setAmazonDynamoDbStreamsClient(com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams amazonDynamoDbStreamsClient)

getMaxResultsPerRequest

public int getMaxResultsPerRequest()

setMaxResultsPerRequest

public void setMaxResultsPerRequest(int maxResultsPerRequest)

getTableName

public String getTableName()

setTableName

public void setTableName(String tableName)

getIteratorType

public com.amazonaws.services.dynamodbv2.model.ShardIteratorType getIteratorType()

setIteratorType

public void setIteratorType(com.amazonaws.services.dynamodbv2.model.ShardIteratorType iteratorType)

getSequenceNumberProvider

public SequenceNumberProvider getSequenceNumberProvider()

setSequenceNumberProvider

public void setSequenceNumberProvider(SequenceNumberProvider sequenceNumberProvider)