Class SqsConsumer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultConsumer
-
- org.apache.camel.support.ScheduledPollConsumer
-
- org.apache.camel.support.ScheduledBatchPollingConsumer
-
- org.apache.camel.component.aws.sqs.SqsConsumer
-
- All Implemented Interfaces:
AutoCloseable
,Runnable
,org.apache.camel.BatchConsumer
,org.apache.camel.Consumer
,org.apache.camel.EndpointAware
,org.apache.camel.PollingConsumerPollingStrategy
,org.apache.camel.RouteAware
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.spi.RouteIdAware
,org.apache.camel.spi.ShutdownAware
,org.apache.camel.spi.ShutdownPrepared
,org.apache.camel.StatefulService
,org.apache.camel.Suspendable
,org.apache.camel.SuspendableService
public class SqsConsumer extends org.apache.camel.support.ScheduledBatchPollingConsumer
A Consumer of messages from the Amazon Web Service Simple Queue Service AWS SQS
-
-
Constructor Summary
Constructors Constructor Description SqsConsumer(SqsEndpoint endpoint, org.apache.camel.Processor processor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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.support.ScheduledBatchPollingConsumer
deferShutdown, getMaxMessagesPerPoll, getPendingExchangesSize, isBatchAllowed, prepareShutdown, processEmptyMessage, setMaxMessagesPerPoll
-
Methods inherited from class org.apache.camel.support.ScheduledPollConsumer
afterPoll, beforePoll, doInit, doStop, doSuspend, getBackoffCounter, getBackoffErrorThreshold, getBackoffIdleThreshold, getBackoffMultiplier, getDelay, getInitialDelay, getPollStrategy, getRepeatCount, getRunLoggingLevel, getScheduledExecutorService, getScheduler, getSchedulerProperties, getTimeUnit, isGreedy, isPollAllowed, isPolling, isSchedulerStarted, isSendEmptyMessageWhenIdle, isStartScheduler, isUseFixedDelay, onInit, run, setBackoffErrorThreshold, setBackoffIdleThreshold, setBackoffMultiplier, setDelay, setGreedy, setInitialDelay, setPollStrategy, setRepeatCount, setRunLoggingLevel, setScheduledExecutorService, setScheduler, setSchedulerProperties, setSendEmptyMessageWhenIdle, setStartScheduler, setTimeUnit, setUseFixedDelay, startScheduler
-
Methods inherited from class org.apache.camel.support.DefaultConsumer
createUoW, doneUoW, getAsyncProcessor, getExceptionHandler, getProcessor, getRoute, getRouteId, handleException, handleException, setExceptionHandler, setRoute, setRouteId
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doLifecycleChange, doResume, fail, getStatus, init, isBuild, isInit, isNew, isRunAllowed, isShutdown, isStarted, isStarting, isStartingOrStarted, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspend
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
-
-
-
Constructor Detail
-
SqsConsumer
public SqsConsumer(SqsEndpoint endpoint, org.apache.camel.Processor processor) throws org.apache.camel.NoFactoryAvailableException
- Throws:
org.apache.camel.NoFactoryAvailableException
-
-
Method Detail
-
poll
protected int poll() throws Exception
- Specified by:
poll
in classorg.apache.camel.support.ScheduledPollConsumer
- Throws:
Exception
-
reConnectToQueue
public void reConnectToQueue()
-
createExchanges
protected Queue<org.apache.camel.Exchange> createExchanges(List<com.amazonaws.services.sqs.model.Message> messages)
-
processCommit
protected void processCommit(org.apache.camel.Exchange exchange)
Strategy to delete the message after being processed.- Parameters:
exchange
- the exchange
-
processRollback
protected void processRollback(org.apache.camel.Exchange exchange)
Strategy when processing the exchange failed.- Parameters:
exchange
- the exchange
-
getConfiguration
protected SqsConfiguration getConfiguration()
-
getClient
protected com.amazonaws.services.sqs.AmazonSQS getClient()
-
getQueueUrl
protected String getQueueUrl()
-
getEndpoint
public SqsEndpoint getEndpoint()
- Specified by:
getEndpoint
in interfaceorg.apache.camel.EndpointAware
- Overrides:
getEndpoint
in classorg.apache.camel.support.DefaultConsumer
-
toString
public String toString()
- Overrides:
toString
in classorg.apache.camel.support.DefaultConsumer
-
doStart
protected void doStart() throws Exception
- Overrides:
doStart
in classorg.apache.camel.support.ScheduledPollConsumer
- Throws:
Exception
-
-