org.apache.camel.component.aws.sqs
Class SqsEndpoint
java.lang.Object
org.apache.camel.support.ServiceSupport
org.apache.camel.impl.DefaultEndpoint
org.apache.camel.impl.ScheduledPollEndpoint
org.apache.camel.component.aws.sqs.SqsEndpoint
- 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
public class SqsEndpoint
- extends org.apache.camel.impl.ScheduledPollEndpoint
Defines the AWS SQS Endpoint.
Fields inherited from class org.apache.camel.support.ServiceSupport |
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending |
Methods inherited from class org.apache.camel.impl.ScheduledPollEndpoint |
configurePollingConsumer, configureProperties, configureScheduledPollConsumerProperties |
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
configureConsumer, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, hashCode, isLenientProperties, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setProperties, setSynchronous, toString |
Methods inherited from class org.apache.camel.support.ServiceSupport |
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend |
Methods inherited from interface org.apache.camel.Service |
start, stop |
SqsEndpoint
public SqsEndpoint(String uri,
SqsComponent component,
SqsConfiguration configuration)
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()
doStart
protected void doStart()
throws Exception
- Overrides:
doStart
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
createQueue
protected void createQueue(com.amazonaws.services.sqs.AmazonSQS client)
doStop
protected void doStop()
throws Exception
- Overrides:
doStop
in class org.apache.camel.impl.DefaultEndpoint
- Throws:
Exception
createExchange
public org.apache.camel.Exchange createExchange(com.amazonaws.services.sqs.model.Message msg)
getConfiguration
public SqsConfiguration getConfiguration()
setConfiguration
public void setConfiguration(SqsConfiguration configuration)
getClient
public com.amazonaws.services.sqs.AmazonSQS getClient()
setClient
public void setClient(com.amazonaws.services.sqs.AmazonSQS client)
getQueueUrl
protected String getQueueUrl()
getMaxMessagesPerPoll
public int getMaxMessagesPerPoll()
setMaxMessagesPerPoll
public void setMaxMessagesPerPoll(int maxMessagesPerPoll)
Apache Camel