@UriEndpoint(scheme="aws-ddb",
syntax="aws-ddb:tableName",
producerOnly=true,
label="cloud,database,nosql")
public class DdbEndpoint
extends org.apache.camel.impl.ScheduledPollEndpoint
Constructor and Description |
---|
DdbEndpoint(String uri,
org.apache.camel.CamelContext context,
DdbConfiguration configuration)
Deprecated.
|
DdbEndpoint(String uri,
org.apache.camel.Component component,
DdbConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
void |
doStart() |
DdbConfiguration |
getConfiguration() |
com.amazonaws.services.dynamodb.AmazonDynamoDB |
getDdbClient() |
boolean |
isSingleton() |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, 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
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
@Deprecated public DdbEndpoint(String uri, org.apache.camel.CamelContext context, DdbConfiguration configuration)
public DdbEndpoint(String uri, org.apache.camel.Component component, DdbConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public void doStart() throws Exception
doStart
in class org.apache.camel.impl.ScheduledPollEndpoint
Exception
public DdbConfiguration getConfiguration()
public com.amazonaws.services.dynamodb.AmazonDynamoDB getDdbClient()
Apache Camel