default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.accessKey(String accessKey) |
Amazon AWS Access Key.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.amazonAWSHost(String amazonAWSHost) |
The hostname of the Amazon AWS cloud.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.amazonSQSClient(Object amazonSQSClient) |
To use the AmazonSQS as client.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.amazonSQSClient(String amazonSQSClient) |
To use the AmazonSQS as client.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.attributeNames(String attributeNames) |
A list of attribute names to receive when consuming.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.autoCreateQueue(boolean autoCreateQueue) |
Setting the autocreation of the queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.autoCreateQueue(String autoCreateQueue) |
Setting the autocreation of the queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.AdvancedSqs2EndpointConsumerBuilder.basic() |
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.concurrentConsumers(int concurrentConsumers) |
Allows you to use multiple threads to poll the sqs queue to increase
throughput.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.concurrentConsumers(String concurrentConsumers) |
Allows you to use multiple threads to poll the sqs queue to increase
throughput.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.defaultVisibilityTimeout(Integer defaultVisibilityTimeout) |
The default visibility timeout (in seconds).
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.defaultVisibilityTimeout(String defaultVisibilityTimeout) |
The default visibility timeout (in seconds).
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.delay(String delay) |
Milliseconds before the next poll.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.deleteAfterRead(boolean deleteAfterRead) |
Delete message from SQS after it has been read.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.deleteAfterRead(String deleteAfterRead) |
Delete message from SQS after it has been read.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.deleteIfFiltered(boolean deleteIfFiltered) |
Whether or not to send the DeleteMessage to the SQS queue if an
exchange fails to get through a filter.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.deleteIfFiltered(String deleteIfFiltered) |
Whether or not to send the DeleteMessage to the SQS queue if an
exchange fails to get through a filter.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.extendMessageVisibility(boolean extendMessageVisibility) |
If enabled then a scheduled background task will keep extending the
message visibility on SQS.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.extendMessageVisibility(String extendMessageVisibility) |
If enabled then a scheduled background task will keep extending the
message visibility on SQS.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.headerFilterStrategy(String headerFilterStrategy) |
To use a custom HeaderFilterStrategy to map headers to/from Camel.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.headerFilterStrategy(org.apache.camel.spi.HeaderFilterStrategy headerFilterStrategy) |
To use a custom HeaderFilterStrategy to map headers to/from Camel.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.kmsMasterKeyId(String kmsMasterKeyId) |
The ID of an AWS-managed customer master key (CMK) for Amazon SQS or
a custom CMK.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.maximumMessageSize(Integer maximumMessageSize) |
The maximumMessageSize (in bytes) an SQS message can contain for this
queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.maximumMessageSize(String maximumMessageSize) |
The maximumMessageSize (in bytes) an SQS message can contain for this
queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.maxMessagesPerPoll(int maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
Gets the maximum number of messages as a limit to poll at each
polling.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.messageAttributeNames(String messageAttributeNames) |
A list of message attribute names to receive when consuming.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.messageRetentionPeriod(Integer messageRetentionPeriod) |
The messageRetentionPeriod (in seconds) a message will be retained by
SQS for this queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.messageRetentionPeriod(String messageRetentionPeriod) |
The messageRetentionPeriod (in seconds) a message will be retained by
SQS for this queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.policy(String policy) |
The policy for this queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.protocol(String protocol) |
The underlying protocol used to communicate with SQS.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.proxyHost(String proxyHost) |
To define a proxy host when instantiating the SQS client.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.proxyPort(Integer proxyPort) |
To define a proxy port when instantiating the SQS client.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.proxyPort(String proxyPort) |
To define a proxy port when instantiating the SQS client.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.proxyProtocol(String proxyProtocol) |
To define a proxy protocol when instantiating the SQS client.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.proxyProtocol(Sqs2EndpointBuilderFactory.Protocol proxyProtocol) |
To define a proxy protocol when instantiating the SQS client.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.queueOwnerAWSAccountId(String queueOwnerAWSAccountId) |
Specify the queue owner aws account id when you need to connect the
queue with different account owner.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.redrivePolicy(String redrivePolicy) |
Specify the policy that send message to DeadLetter queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.region(String region) |
The region in which SQS client needs to work.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.secretKey(String secretKey) |
Amazon AWS Secret Key.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.serverSideEncryptionEnabled(boolean serverSideEncryptionEnabled) |
Define if Server Side Encryption is enabled or not on the queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.serverSideEncryptionEnabled(String serverSideEncryptionEnabled) |
Define if Server Side Encryption is enabled or not on the queue.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.trustAllCertificates(boolean trustAllCertificates) |
If we want to trust all certificates in case of overriding the
endpoint.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.trustAllCertificates(String trustAllCertificates) |
If we want to trust all certificates in case of overriding the
endpoint.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.useDefaultCredentialsProvider(boolean useDefaultCredentialsProvider) |
Set whether the SQS client should expect to load credentials on an
AWS infra instance or to expect static credentials to be passed in.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.useDefaultCredentialsProvider(String useDefaultCredentialsProvider) |
Set whether the SQS client should expect to load credentials on an
AWS infra instance or to expect static credentials to be passed in.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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 Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder |
Sqs2EndpointBuilderFactory.Sqs2EndpointConsumerBuilder.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.
|