Class Sns2Configuration
- java.lang.Object
-
- org.apache.camel.component.aws2.sns.Sns2Configuration
-
-
Constructor Summary
Constructors Constructor Description Sns2Configuration()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Sns2Configuration
copy()
String
getAccessKey()
software.amazon.awssdk.services.sns.SnsClient
getAmazonSNSClient()
String
getKmsMasterKeyId()
MessageDeduplicationIdStrategy
getMessageDeduplicationIdStrategy()
MessageGroupIdStrategy
getMessageGroupIdStrategy()
String
getMessageStructure()
String
getPolicy()
String
getProxyHost()
Integer
getProxyPort()
software.amazon.awssdk.core.Protocol
getProxyProtocol()
String
getQueueUrl()
String
getRegion()
String
getSecretKey()
String
getSubject()
String
getTopicArn()
String
getTopicName()
boolean
isAutoCreateTopic()
boolean
isServerSideEncryptionEnabled()
boolean
isSubscribeSNStoSQS()
boolean
isTrustAllCertificates()
boolean
isUseDefaultCredentialsProvider()
void
setAccessKey(String accessKey)
Amazon AWS Access Keyvoid
setAmazonSNSClient(software.amazon.awssdk.services.sns.SnsClient amazonSNSClient)
To use the AmazonSNS as the clientvoid
setAutoCreateTopic(boolean autoCreateTopic)
Setting the autocreation of the topicvoid
setKmsMasterKeyId(String kmsMasterKeyId)
The ID of an AWS-managed customer master key (CMK) for Amazon SNS or a custom CMK.void
setMessageDeduplicationIdStrategy(String strategy)
Only for FIFO Topic.void
setMessageDeduplicationIdStrategy(MessageDeduplicationIdStrategy messageDeduplicationIdStrategy)
void
setMessageGroupIdStrategy(String strategy)
Only for FIFO Topic.void
setMessageGroupIdStrategy(MessageGroupIdStrategy messageGroupIdStrategy)
void
setMessageStructure(String messageStructure)
The message structure to use such as jsonvoid
setPolicy(String policy)
The policy for this queuevoid
setProxyHost(String proxyHost)
To define a proxy host when instantiating the SNS clientvoid
setProxyPort(Integer proxyPort)
To define a proxy port when instantiating the SNS clientvoid
setProxyProtocol(software.amazon.awssdk.core.Protocol proxyProtocol)
To define a proxy protocol when instantiating the SNS clientvoid
setQueueUrl(String queueUrl)
The queueUrl to subscribe tovoid
setRegion(String region)
The region in which SNS client needs to work.void
setSecretKey(String secretKey)
Amazon AWS Secret Keyvoid
setServerSideEncryptionEnabled(boolean serverSideEncryptionEnabled)
Define if Server Side Encryption is enabled or not on the topicvoid
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 notvoid
setTopicArn(String topicArn)
The Amazon Resource Name (ARN) assigned to the created topic.void
setTopicName(String topicName)
The name of the topicvoid
setTrustAllCertificates(boolean trustAllCertificates)
If we want to trust all certificates in case of overriding the endpointvoid
setUseDefaultCredentialsProvider(boolean useDefaultCredentialsProvider)
Set whether the SNS client should expect to load credentials on an AWS infra instance or to expect static credentials to be passed in.
-
-
-
Method Detail
-
getSubject
public String getSubject()
-
setSubject
public void setSubject(String subject)
The subject which is used if the message header 'CamelAwsSnsSubject' is not present.
-
getTopicArn
public String getTopicArn()
-
setTopicArn
public void setTopicArn(String topicArn)
The Amazon Resource Name (ARN) assigned to the created topic.
-
getAccessKey
public String getAccessKey()
-
setAccessKey
public void setAccessKey(String accessKey)
Amazon AWS Access Key
-
getSecretKey
public String getSecretKey()
-
setSecretKey
public void setSecretKey(String secretKey)
Amazon AWS Secret Key
-
getAmazonSNSClient
public software.amazon.awssdk.services.sns.SnsClient getAmazonSNSClient()
-
setAmazonSNSClient
public void setAmazonSNSClient(software.amazon.awssdk.services.sns.SnsClient amazonSNSClient)
To use the AmazonSNS as the client
-
getTopicName
public String getTopicName()
-
setTopicName
public void setTopicName(String topicName)
The name of the topic
-
getPolicy
public String getPolicy()
-
setPolicy
public void setPolicy(String policy)
The policy for this queue
-
getMessageStructure
public String getMessageStructure()
-
setMessageStructure
public void setMessageStructure(String messageStructure)
The message structure to use such as json
-
getProxyProtocol
public software.amazon.awssdk.core.Protocol getProxyProtocol()
-
setProxyProtocol
public void setProxyProtocol(software.amazon.awssdk.core.Protocol proxyProtocol)
To define a proxy protocol when instantiating the SNS client
-
getProxyHost
public String getProxyHost()
-
setProxyHost
public void setProxyHost(String proxyHost)
To define a proxy host when instantiating the SNS client
-
getProxyPort
public Integer getProxyPort()
-
setProxyPort
public void setProxyPort(Integer proxyPort)
To define a proxy port when instantiating the SNS client
-
getRegion
public String getRegion()
-
setRegion
public void setRegion(String region)
The region in which SNS client needs to work. When using this parameter, the configuration will expect the lowercase name of the region (for example ap-east-1) You'll need to use the name Region.EU_WEST_1.id()
-
getQueueUrl
public String getQueueUrl()
-
setQueueUrl
public void setQueueUrl(String queueUrl)
The queueUrl to subscribe to
-
isSubscribeSNStoSQS
public boolean isSubscribeSNStoSQS()
-
setSubscribeSNStoSQS
public void setSubscribeSNStoSQS(boolean subscribeSNStoSQS)
Define if the subscription between SNS Topic and SQS must be done or not
-
getKmsMasterKeyId
public String getKmsMasterKeyId()
-
setKmsMasterKeyId
public void setKmsMasterKeyId(String kmsMasterKeyId)
The ID of an AWS-managed customer master key (CMK) for Amazon SNS or a custom CMK.
-
isServerSideEncryptionEnabled
public boolean isServerSideEncryptionEnabled()
-
setServerSideEncryptionEnabled
public void setServerSideEncryptionEnabled(boolean serverSideEncryptionEnabled)
Define if Server Side Encryption is enabled or not on the topic
-
isAutoCreateTopic
public boolean isAutoCreateTopic()
-
setAutoCreateTopic
public void setAutoCreateTopic(boolean autoCreateTopic)
Setting the autocreation of the topic
-
isTrustAllCertificates
public boolean isTrustAllCertificates()
-
setTrustAllCertificates
public void setTrustAllCertificates(boolean trustAllCertificates)
If we want to trust all certificates in case of overriding the endpoint
-
isUseDefaultCredentialsProvider
public boolean isUseDefaultCredentialsProvider()
-
setUseDefaultCredentialsProvider
public void setUseDefaultCredentialsProvider(boolean useDefaultCredentialsProvider)
Set whether the SNS client should expect to load credentials on an AWS infra instance or to expect static credentials to be passed in.
-
setMessageGroupIdStrategy
public void setMessageGroupIdStrategy(String strategy)
Only for FIFO Topic. Strategy for setting the messageGroupId on the message. Can be one of the following options: *useConstant*, *useExchangeId*, *usePropertyValue*. For the *usePropertyValue* option, the value of property "CamelAwsMessageGroupId" will be used.
-
setMessageGroupIdStrategy
public void setMessageGroupIdStrategy(MessageGroupIdStrategy messageGroupIdStrategy)
-
getMessageGroupIdStrategy
public MessageGroupIdStrategy getMessageGroupIdStrategy()
-
getMessageDeduplicationIdStrategy
public MessageDeduplicationIdStrategy getMessageDeduplicationIdStrategy()
-
setMessageDeduplicationIdStrategy
public void setMessageDeduplicationIdStrategy(String strategy)
Only for FIFO Topic. Strategy for setting the messageDeduplicationId on the message. Can be one of the following options: *useExchangeId*, *useContentBasedDeduplication*. For the *useContentBasedDeduplication* option, no messageDeduplicationId will be set on the message.
-
setMessageDeduplicationIdStrategy
public void setMessageDeduplicationIdStrategy(MessageDeduplicationIdStrategy messageDeduplicationIdStrategy)
-
copy
public Sns2Configuration copy()
-
-