| Constructor and Description |
|---|
SnsConfiguration() |
| Modifier and Type | Method and Description |
|---|---|
SnsConfiguration |
copy() |
String |
getAccessKey() |
com.amazonaws.services.sns.AmazonSNS |
getAmazonSNSClient() |
com.amazonaws.services.sqs.AmazonSQS |
getAmazonSQSClient() |
String |
getKmsMasterKeyId() |
String |
getMessageStructure() |
String |
getPolicy() |
String |
getProxyHost() |
Integer |
getProxyPort() |
com.amazonaws.Protocol |
getProxyProtocol() |
String |
getQueueUrl() |
String |
getRegion() |
String |
getSecretKey() |
String |
getSubject() |
String |
getTopicArn() |
String |
getTopicName() |
boolean |
isAutoCreateTopic() |
boolean |
isAutoDiscoverClient() |
boolean |
isServerSideEncryptionEnabled() |
boolean |
isSubscribeSNStoSQS() |
void |
setAccessKey(String accessKey)
Amazon AWS Access Key
|
void |
setAmazonSNSClient(com.amazonaws.services.sns.AmazonSNS amazonSNSClient)
To use the AmazonSNS as the client
|
void |
setAmazonSQSClient(com.amazonaws.services.sqs.AmazonSQS amazonSQSClient)
An SQS Client to use as bridge between SNS and SQS
|
void |
setAutoCreateTopic(boolean autoCreateTopic)
Setting the autocreation of the topic
|
void |
setAutoDiscoverClient(boolean autoDiscoverClient)
Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking.
|
void |
setKmsMasterKeyId(String kmsMasterKeyId)
The ID of an AWS-managed customer master key (CMK) for Amazon SNS or a custom CMK.
|
void |
setMessageStructure(String messageStructure)
The message structure to use such as json
|
void |
setPolicy(String policy)
The policy for this queue
|
void |
setProxyHost(String proxyHost)
To define a proxy host when instantiating the SNS client
|
void |
setProxyPort(Integer proxyPort)
To define a proxy port when instantiating the SNS client
|
void |
setProxyProtocol(com.amazonaws.Protocol proxyProtocol)
To define a proxy protocol when instantiating the SNS client
|
void |
setQueueUrl(String queueUrl)
The queueUrl to subscribe to
|
void |
setRegion(String region)
The region in which SNS client needs to work.
|
void |
setSecretKey(String secretKey)
Amazon AWS Secret Key
|
void |
setServerSideEncryptionEnabled(boolean serverSideEncryptionEnabled)
Define if Server Side Encryption is enabled or not on the topic
|
void |
setSubject(String subject)
The subject which is used if the message header 'CamelAwsSnsSubject' is not present.
|
void |
setSubscribeSNStoSQS(boolean subscribeSNStoSQS)
Define if the subscription between SNS Topic and SQS must be done or not
|
void |
setTopicArn(String topicArn)
The Amazon Resource Name (ARN) assigned to the created topic.
|
void |
setTopicName(String topicName)
The name of the topic
|
public String getSubject()
public void setSubject(String subject)
public String getTopicArn()
public void setTopicArn(String topicArn)
public String getAccessKey()
public void setAccessKey(String accessKey)
public String getSecretKey()
public void setSecretKey(String secretKey)
public com.amazonaws.services.sns.AmazonSNS getAmazonSNSClient()
public void setAmazonSNSClient(com.amazonaws.services.sns.AmazonSNS amazonSNSClient)
public String getTopicName()
public void setTopicName(String topicName)
public String getPolicy()
public void setPolicy(String policy)
public String getMessageStructure()
public void setMessageStructure(String messageStructure)
public com.amazonaws.Protocol getProxyProtocol()
public void setProxyProtocol(com.amazonaws.Protocol proxyProtocol)
public String getProxyHost()
public void setProxyHost(String proxyHost)
public Integer getProxyPort()
public void setProxyPort(Integer proxyPort)
public String getRegion()
public void setRegion(String region)
public com.amazonaws.services.sqs.AmazonSQS getAmazonSQSClient()
public void setAmazonSQSClient(com.amazonaws.services.sqs.AmazonSQS amazonSQSClient)
public String getQueueUrl()
public void setQueueUrl(String queueUrl)
public boolean isSubscribeSNStoSQS()
public void setSubscribeSNStoSQS(boolean subscribeSNStoSQS)
public String getKmsMasterKeyId()
public void setKmsMasterKeyId(String kmsMasterKeyId)
public boolean isServerSideEncryptionEnabled()
public void setServerSideEncryptionEnabled(boolean serverSideEncryptionEnabled)
public boolean isAutoCreateTopic()
public void setAutoCreateTopic(boolean autoCreateTopic)
public boolean isAutoDiscoverClient()
public void setAutoDiscoverClient(boolean autoDiscoverClient)
public SnsConfiguration copy()
Apache Camel