org.apache.camel.component.aws.sqs
Class SqsEndpoint

java.lang.Object
  extended by org.apache.camel.support.ServiceSupport
      extended by org.apache.camel.impl.DefaultEndpoint
          extended by org.apache.camel.impl.ScheduledPollEndpoint
              extended by 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.


Field Summary
 
Fields inherited from class org.apache.camel.support.ServiceSupport
shutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending
 
Constructor Summary
SqsEndpoint(String uri, SqsComponent component, SqsConfiguration configuration)
           
 
Method Summary
 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()
           
 int getMaxMessagesPerPoll()
           
protected  String getQueueUrl()
           
 boolean isSingleton()
           
 void setClient(com.amazonaws.services.sqs.AmazonSQS client)
           
 void setConfiguration(SqsConfiguration configuration)
           
 void setMaxMessagesPerPoll(int maxMessagesPerPoll)
           
 
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 class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

SqsEndpoint

public SqsEndpoint(String uri,
                   SqsComponent component,
                   SqsConfiguration configuration)
Method Detail

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