default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.accessKey(String accessKey) |
Amazon AWS Access Key.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.amazonAWSHost(String amazonAWSHost) |
The hostname of the Amazon AWS cloud.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.amazonSQSClient(Object amazonSQSClient) |
To use the AmazonSQS as client.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.amazonSQSClient(String amazonSQSClient) |
To use the AmazonSQS as client.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.attributeNames(String attributeNames) |
A list of attribute names to receive when consuming.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.autoCreateQueue(boolean autoCreateQueue) |
Setting the autocreation of the queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.autoCreateQueue(String autoCreateQueue) |
Setting the autocreation of the queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.autoDiscoverClient(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.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.autoDiscoverClient(String 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.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.AdvancedSqsEndpointConsumerBuilder.basic() |
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.concurrentConsumers(int concurrentConsumers) |
Allows you to use multiple threads to poll the sqs queue to increase
throughput.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.concurrentConsumers(String concurrentConsumers) |
Allows you to use multiple threads to poll the sqs queue to increase
throughput.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.defaultVisibilityTimeout(Integer defaultVisibilityTimeout) |
The default visibility timeout (in seconds).
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.defaultVisibilityTimeout(String defaultVisibilityTimeout) |
The default visibility timeout (in seconds).
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.delay(String delay) |
Milliseconds before the next poll.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.deleteAfterRead(boolean deleteAfterRead) |
Delete message from SQS after it has been read.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.deleteAfterRead(String deleteAfterRead) |
Delete message from SQS after it has been read.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.deleteIfFiltered(boolean deleteIfFiltered) |
Whether or not to send the DeleteMessage to the SQS queue if an
exchange fails to get through a filter.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.deleteIfFiltered(String deleteIfFiltered) |
Whether or not to send the DeleteMessage to the SQS queue if an
exchange fails to get through a filter.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.extendMessageVisibility(boolean extendMessageVisibility) |
If enabled then a scheduled background task will keep extending the
message visibility on SQS.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.extendMessageVisibility(String extendMessageVisibility) |
If enabled then a scheduled background task will keep extending the
message visibility on SQS.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.headerFilterStrategy(String headerFilterStrategy) |
To use a custom HeaderFilterStrategy to map headers to/from Camel.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
To use a custom HeaderFilterStrategy to map headers to/from Camel.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.kmsDataKeyReusePeriodSeconds(Integer kmsDataKeyReusePeriodSeconds) |
The length of time, in seconds, for which Amazon SQS can reuse a data
key to encrypt or decrypt messages before calling AWS KMS again.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.kmsDataKeyReusePeriodSeconds(String kmsDataKeyReusePeriodSeconds) |
The length of time, in seconds, for which Amazon SQS can reuse a data
key to encrypt or decrypt messages before calling AWS KMS again.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.kmsMasterKeyId(String kmsMasterKeyId) |
The ID of an AWS-managed customer master key (CMK) for Amazon SQS or
a custom CMK.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.maximumMessageSize(Integer maximumMessageSize) |
The maximumMessageSize (in bytes) an SQS message can contain for this
queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.maximumMessageSize(String maximumMessageSize) |
The maximumMessageSize (in bytes) an SQS message can contain for this
queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.maxMessagesPerPoll(int maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.messageAttributeNames(String messageAttributeNames) |
A list of message attribute names to receive when consuming.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.messageRetentionPeriod(Integer messageRetentionPeriod) |
The messageRetentionPeriod (in seconds) a message will be retained by
SQS for this queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.messageRetentionPeriod(String messageRetentionPeriod) |
The messageRetentionPeriod (in seconds) a message will be retained by
SQS for this queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.policy(String policy) |
The policy for this queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.protocol(String protocol) |
The underlying protocol used to communicate with SQS.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.proxyHost(String proxyHost) |
To define a proxy host when instantiating the SQS client.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.proxyPort(Integer proxyPort) |
To define a proxy port when instantiating the SQS client.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.proxyPort(String proxyPort) |
To define a proxy port when instantiating the SQS client.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.proxyProtocol(String proxyProtocol) |
To define a proxy protocol when instantiating the SQS client.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.proxyProtocol(SqsEndpointBuilderFactory.Protocol proxyProtocol) |
To define a proxy protocol when instantiating the SQS client.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.queueOwnerAWSAccountId(String queueOwnerAWSAccountId) |
Specify the queue owner aws account id when you need to connect the
queue with different account owner.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.receiveMessageWaitTimeSeconds(Integer receiveMessageWaitTimeSeconds) |
If you do not specify WaitTimeSeconds in the request, the queue
attribute ReceiveMessageWaitTimeSeconds is used to determine how long
to wait.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.receiveMessageWaitTimeSeconds(String receiveMessageWaitTimeSeconds) |
If you do not specify WaitTimeSeconds in the request, the queue
attribute ReceiveMessageWaitTimeSeconds is used to determine how long
to wait.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.redrivePolicy(String redrivePolicy) |
Specify the policy that send message to DeadLetter queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.region(String region) |
Specify the queue region which could be used with
queueOwnerAWSAccountId to build the service URL.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.secretKey(String secretKey) |
Amazon AWS Secret Key.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.sendEmptyMessageWhenIdle(boolean sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.sendEmptyMessageWhenIdle(String sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.serverSideEncryptionEnabled(boolean serverSideEncryptionEnabled) |
Define if Server Side Encryption is enabled or not on the queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.serverSideEncryptionEnabled(String serverSideEncryptionEnabled) |
Define if Server Side Encryption is enabled or not on the queue.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.visibilityTimeout(Integer visibilityTimeout) |
The duration (in seconds) that the received messages are hidden from
subsequent retrieve requests after being retrieved by a
ReceiveMessage request to set in the
com.amazonaws.services.sqs.model.SetQueueAttributesRequest.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.visibilityTimeout(String visibilityTimeout) |
The duration (in seconds) that the received messages are hidden from
subsequent retrieve requests after being retrieved by a
ReceiveMessage request to set in the
com.amazonaws.services.sqs.model.SetQueueAttributesRequest.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.waitTimeSeconds(Integer waitTimeSeconds) |
Duration in seconds (0 to 20) that the ReceiveMessage action call
will wait until a message is in the queue to include in the response.
|
default SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder |
SqsEndpointBuilderFactory.SqsEndpointConsumerBuilder.waitTimeSeconds(String waitTimeSeconds) |
Duration in seconds (0 to 20) that the ReceiveMessage action call
will wait until a message is in the queue to include in the response.
|