Class SqsProducer
- java.lang.Object
-
- org.apache.camel.support.service.BaseService
-
- org.apache.camel.support.service.ServiceSupport
-
- org.apache.camel.support.DefaultProducer
-
- org.apache.camel.component.aws.sqs.SqsProducer
-
- All Implemented Interfaces:
AutoCloseable
,org.apache.camel.EndpointAware
,org.apache.camel.IsSingleton
,org.apache.camel.Processor
,org.apache.camel.Producer
,org.apache.camel.Service
,org.apache.camel.ShutdownableService
,org.apache.camel.StatefulService
,org.apache.camel.SuspendableService
public class SqsProducer extends org.apache.camel.support.DefaultProducer
A Producer which sends messages to the Amazon Web Service Simple Queue Service AWS SQS
-
-
Constructor Summary
Constructors Constructor Description SqsProducer(SqsEndpoint endpoint)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description protected com.amazonaws.services.sqs.AmazonSQS
getClient()
protected SqsConfiguration
getConfiguration()
SqsEndpoint
getEndpoint()
static org.apache.camel.Message
getMessageForResponse(org.apache.camel.Exchange exchange)
protected String
getQueueUrl()
void
process(org.apache.camel.Exchange exchange)
void
processSingleMessage(org.apache.camel.Exchange exchange)
String
toString()
-
Methods inherited from class org.apache.camel.support.DefaultProducer
createExchange, doStart, doStop, isSingleton
-
Methods inherited from class org.apache.camel.support.service.BaseService
build, doBuild, doFail, doInit, doLifecycleChange, doResume, doShutdown, doSuspend, 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
-
SqsProducer
public SqsProducer(SqsEndpoint endpoint) throws org.apache.camel.NoFactoryAvailableException
- Throws:
org.apache.camel.NoFactoryAvailableException
-
-
Method Detail
-
processSingleMessage
public void processSingleMessage(org.apache.camel.Exchange exchange)
-
getClient
protected com.amazonaws.services.sqs.AmazonSQS getClient()
-
getQueueUrl
protected String getQueueUrl()
-
getConfiguration
protected SqsConfiguration getConfiguration()
-
getEndpoint
public SqsEndpoint getEndpoint()
- Specified by:
getEndpoint
in interfaceorg.apache.camel.EndpointAware
- Overrides:
getEndpoint
in classorg.apache.camel.support.DefaultProducer
-
toString
public String toString()
- Overrides:
toString
in classorg.apache.camel.support.DefaultProducer
-
getMessageForResponse
public static org.apache.camel.Message getMessageForResponse(org.apache.camel.Exchange exchange)
-
-