|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.camel.support.ServiceSupport org.apache.camel.impl.DefaultConsumer org.apache.camel.impl.ScheduledPollConsumer org.apache.camel.impl.ScheduledBatchPollingConsumer org.apache.camel.component.aws.sqs.SqsConsumer
public class SqsConsumer
A Consumer of messages from the Amazon Web Service Simple Queue Service AWS SQS
Field Summary |
---|
Fields inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer |
---|
maxMessagesPerPoll, pendingExchanges, shutdownRunningTask |
Fields inherited from class org.apache.camel.impl.DefaultConsumer |
---|
log |
Fields inherited from class org.apache.camel.support.ServiceSupport |
---|
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Constructor Summary | |
---|---|
SqsConsumer(SqsEndpoint endpoint,
org.apache.camel.Processor processor)
|
Method Summary | |
---|---|
protected Queue<org.apache.camel.Exchange> |
createExchanges(List<com.amazonaws.services.sqs.model.Message> messages)
|
protected void |
doShutdown()
|
protected void |
doStart()
|
protected com.amazonaws.services.sqs.AmazonSQS |
getClient()
|
protected SqsConfiguration |
getConfiguration()
|
SqsEndpoint |
getEndpoint()
|
protected String |
getQueueUrl()
|
protected int |
poll()
|
int |
processBatch(Queue<Object> exchanges)
|
protected void |
processCommit(org.apache.camel.Exchange exchange)
Strategy to delete the message after being processed. |
protected void |
processRollback(org.apache.camel.Exchange exchange)
Strategy when processing the exchange failed. |
void |
reConnectToQueue()
|
String |
toString()
|
Methods inherited from class org.apache.camel.impl.ScheduledBatchPollingConsumer |
---|
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPoll |
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer |
---|
afterPoll, beforePoll, doStop, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler |
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
---|
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, handleException, handleException, setExceptionHandler, setRoute |
Methods inherited from class org.apache.camel.support.ServiceSupport |
---|
doResume, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.camel.Service |
---|
start, stop |
Methods inherited from interface org.apache.camel.SuspendableService |
---|
isSuspended, resume, suspend |
Constructor Detail |
---|
public SqsConsumer(SqsEndpoint endpoint, org.apache.camel.Processor processor) throws org.apache.camel.NoFactoryAvailableException
org.apache.camel.NoFactoryAvailableException
Method Detail |
---|
protected int poll() throws Exception
poll
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
public void reConnectToQueue()
protected Queue<org.apache.camel.Exchange> createExchanges(List<com.amazonaws.services.sqs.model.Message> messages)
public int processBatch(Queue<Object> exchanges) throws Exception
Exception
protected void processCommit(org.apache.camel.Exchange exchange)
exchange
- the exchangeprotected void processRollback(org.apache.camel.Exchange exchange)
exchange
- the exchangeprotected SqsConfiguration getConfiguration()
protected com.amazonaws.services.sqs.AmazonSQS getClient()
protected String getQueueUrl()
public SqsEndpoint getEndpoint()
getEndpoint
in interface org.apache.camel.Consumer
getEndpoint
in class org.apache.camel.impl.DefaultConsumer
public String toString()
toString
in class org.apache.camel.impl.DefaultConsumer
protected void doStart() throws Exception
doStart
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
protected void doShutdown() throws Exception
doShutdown
in class org.apache.camel.impl.ScheduledPollConsumer
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |