@UriEndpoint(scheme="aws-sqs", syntax="aws-sqs:queueName", consumerClass=SqsConsumer.class, label="cloud,messaging") public class SqsEndpoint extends org.apache.camel.impl.ScheduledPollEndpoint implements org.apache.camel.spi.HeaderFilterStrategyAware
Constructor and Description |
---|
SqsEndpoint(String uri,
SqsComponent component,
SqsConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Exchange |
createExchange(com.amazonaws.services.sqs.model.Message msg) |
org.apache.camel.Producer |
createProducer() |
protected void |
createQueue(com.amazonaws.services.sqs.AmazonSQS client) |
protected void |
doStart() |
protected void |
doStop() |
com.amazonaws.services.sqs.AmazonSQS |
getClient() |
SqsConfiguration |
getConfiguration() |
org.apache.camel.spi.HeaderFilterStrategy |
getHeaderFilterStrategy() |
int |
getMaxMessagesPerPoll() |
protected String |
getQueueUrl() |
boolean |
isSingleton() |
void |
setClient(com.amazonaws.services.sqs.AmazonSQS client) |
void |
setConfiguration(SqsConfiguration configuration) |
void |
setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy) |
void |
setMaxMessagesPerPoll(int maxMessagesPerPoll) |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties, 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
public SqsEndpoint(String uri, SqsComponent component, SqsConfiguration configuration)
public org.apache.camel.spi.HeaderFilterStrategy getHeaderFilterStrategy()
getHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public void setHeaderFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy strategy)
setHeaderFilterStrategy
in interface org.apache.camel.spi.HeaderFilterStrategyAware
public org.apache.camel.Producer createProducer() throws Exception
createProducer
in interface org.apache.camel.Endpoint
Exception
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
createConsumer
in interface org.apache.camel.Endpoint
Exception
public boolean isSingleton()
isSingleton
in interface org.apache.camel.IsSingleton
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.ScheduledPollEndpoint
Exception
protected void createQueue(com.amazonaws.services.sqs.AmazonSQS client)
protected void doStop() throws Exception
doStop
in class org.apache.camel.impl.ScheduledPollEndpoint
Exception
public org.apache.camel.Exchange createExchange(com.amazonaws.services.sqs.model.Message msg)
public SqsConfiguration getConfiguration()
public void setConfiguration(SqsConfiguration configuration)
public com.amazonaws.services.sqs.AmazonSQS getClient()
public void setClient(com.amazonaws.services.sqs.AmazonSQS client)
protected String getQueueUrl()
public int getMaxMessagesPerPoll()
public void setMaxMessagesPerPoll(int maxMessagesPerPoll)
Apache Camel