Package com.flowable.spring.boot.aws.sqs
Class FlowableAwsSqsProperties
java.lang.Object
com.flowable.spring.boot.aws.sqs.FlowableAwsSqsProperties
@ConfigurationProperties(prefix="flowable.aws.sqs")
public class FlowableAwsSqsProperties
extends java.lang.Object
Properties for the AWS SQS SDK
- Author:
- Filip Hrisafov
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.Integer
executorPoolSize
The number of threads that should be used for executing the SQS messages.protected java.lang.Integer
maxNumberOfMessages
The default max number of messages to return when requesting messages.protected SqsMessageDeletionPolicy
messageDeletionPolicy
The deletion policy for the messages.protected java.time.Duration
visibilityTimeout
The default duration that the received messages are hidden from subsequent retrieve requests after being retrieved via the ReceiveMessage request.protected java.time.Duration
waitTime
The default duration for which the retrieve message calls waits for messages to arrive in the queue before returning. -
Constructor Summary
Constructors Constructor Description FlowableAwsSqsProperties()
-
Method Summary
Modifier and Type Method Description java.lang.Integer
getExecutorPoolSize()
java.lang.Integer
getMaxNumberOfMessages()
SqsMessageDeletionPolicy
getMessageDeletionPolicy()
java.time.Duration
getVisibilityTimeout()
java.time.Duration
getWaitTime()
void
setExecutorPoolSize(java.lang.Integer executorPoolSize)
void
setMaxNumberOfMessages(java.lang.Integer maxNumberOfMessages)
void
setMessageDeletionPolicy(SqsMessageDeletionPolicy messageDeletionPolicy)
void
setVisibilityTimeout(java.time.Duration visibilityTimeout)
void
setWaitTime(java.time.Duration waitTime)
-
Field Details
-
executorPoolSize
protected java.lang.Integer executorPoolSizeThe number of threads that should be used for executing the SQS messages. -
maxNumberOfMessages
protected java.lang.Integer maxNumberOfMessagesThe default max number of messages to return when requesting messages. This can be overridden on a case by case basis in the channel definition model, Valid values are only between 1 and 10. -
visibilityTimeout
@DurationUnit(SECONDS) protected java.time.Duration visibilityTimeoutThe default duration that the received messages are hidden from subsequent retrieve requests after being retrieved via the ReceiveMessage request. This can be overridden on a case by case basis in the channel definition model. -
waitTime
@DurationUnit(SECONDS) protected java.time.Duration waitTimeThe default duration for which the retrieve message calls waits for messages to arrive in the queue before returning. See the AWS SDK documentation about long polling for more information. This can be overridden on a case by case basis in the channel definition model. -
messageDeletionPolicy
The deletion policy for the messages. By default messages are deleted on exception when the queue has no redrive policy.
-
-
Constructor Details
-
FlowableAwsSqsProperties
public FlowableAwsSqsProperties()
-
-
Method Details
-
getExecutorPoolSize
public java.lang.Integer getExecutorPoolSize() -
setExecutorPoolSize
public void setExecutorPoolSize(java.lang.Integer executorPoolSize) -
getMaxNumberOfMessages
public java.lang.Integer getMaxNumberOfMessages() -
setMaxNumberOfMessages
public void setMaxNumberOfMessages(java.lang.Integer maxNumberOfMessages) -
getVisibilityTimeout
public java.time.Duration getVisibilityTimeout() -
setVisibilityTimeout
public void setVisibilityTimeout(java.time.Duration visibilityTimeout) -
getWaitTime
public java.time.Duration getWaitTime() -
setWaitTime
public void setWaitTime(java.time.Duration waitTime) -
getMessageDeletionPolicy
-
setMessageDeletionPolicy
-