@UriEndpoint(scheme="aws-sns",
syntax="aws-sns:topicName",
producerOnly=true,
label="cloud,mobile,messaging")
public class SnsEndpoint
extends org.apache.camel.impl.DefaultEndpoint
Constructor and Description |
---|
SnsEndpoint(String uri,
org.apache.camel.CamelContext context,
SnsConfiguration configuration)
Deprecated.
|
SnsEndpoint(String uri,
org.apache.camel.Component component,
SnsConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
org.apache.camel.Consumer |
createConsumer(org.apache.camel.Processor processor) |
org.apache.camel.Producer |
createProducer() |
void |
doStart() |
SnsConfiguration |
getConfiguration() |
com.amazonaws.services.sns.AmazonSNS |
getSNSClient() |
boolean |
isSingleton() |
void |
setConfiguration(SnsConfiguration configuration) |
void |
setSNSClient(com.amazonaws.services.sns.AmazonSNS snsClient) |
configureConsumer, configurePollingConsumer, configureProperties, createEndpointConfiguration, createEndpointUri, createExchange, createExchange, createExchange, createPollingConsumer, doStop, equals, getCamelContext, getComponent, getConsumerProperties, getEndpointConfiguration, getEndpointKey, getEndpointUri, getExchangePattern, getId, getPollingConsumerQueueSize, hashCode, isLenientProperties, isPollingConsumerBlockWhenFull, isSynchronous, setCamelContext, setConsumerProperties, setEndpointConfiguration, setEndpointUri, setEndpointUriIfNotSpecified, setExchangePattern, setPollingConsumerBlockWhenFull, setPollingConsumerQueueSize, setProperties, setSynchronous, toString
doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, resume, shutdown, start, stop, suspend
@Deprecated public SnsEndpoint(String uri, org.apache.camel.CamelContext context, SnsConfiguration configuration)
public SnsEndpoint(String uri, org.apache.camel.Component component, SnsConfiguration configuration)
public org.apache.camel.Consumer createConsumer(org.apache.camel.Processor processor) throws Exception
Exception
public boolean isSingleton()
public void doStart() throws Exception
doStart
in class org.apache.camel.impl.DefaultEndpoint
Exception
public SnsConfiguration getConfiguration()
public void setConfiguration(SnsConfiguration configuration)
public void setSNSClient(com.amazonaws.services.sns.AmazonSNS snsClient)
public com.amazonaws.services.sns.AmazonSNS getSNSClient()
Apache Camel