feat: add batch processing configuration to SQS properties

Author: khc41

spring-cloud-aws-autoconfigure/src/main/java/io/awspring/cloud/autoconfigure/sqs/SqsProperties.java

@@ -41,6 +41,8 @@ public class SqsProperties extends AwsClientProperties {
 
 	private Listener listener = new Listener();
 
+	private Batch batch = new Batch();
+
 	public Listener getListener() {
 		return this.listener;
 	}
@@ -49,6 +51,14 @@ public void setListener(Listener listener) {
 		this.listener = listener;
 	}
 
+	public Batch getBatch() {
+		return batch;
+	}
+
+	public void setBatch(Batch batch) {
+		this.batch = batch;
+	}
+
 	@Nullable
 	private QueueNotFoundStrategy queueNotFoundStrategy;
 
@@ -147,40 +157,61 @@ public void setMaxDelayBetweenPolls(Duration maxDelayBetweenPolls) {
 
 	public static class Batch {
 
+		/**
+		 * Enables SQS automatic batching using AWS SDK's SqsAsyncBatchManager.
+		 */
+		private boolean enabled = false;
+
 		/**
 		 * The maximum number of messages that can be processed in a single batch. The
 		 * maximum is 10.
 		 */
+		@Nullable
 		private Integer maxNumberOfMessages;
 
 		/**
 		 * The frequency at which requests are sent to SQS when processing messages in a
 		 * batch.
 		 */
+		@Nullable
 		private Duration sendBatchFrequency;
 
 		/**
 		 * The visibility timeout to set for messages received in a batch. If unset, the
 		 * queue default is used.
 		 */
+		@Nullable
 		private Duration visibilityTimeout;
 
 		/**
 		 * The minimum wait duration for a receiveMessage request in a batch. To avoid
 		 * unnecessary CPU usage, do not set this value to 0.
 		 */
+		@Nullable
 		private Duration waitTimeSeconds;
 
 		/**
 		 * The list of system attribute names to request for receiveMessage calls.
 		 */
+		@Nullable
 		private List<MessageSystemAttributeName> systemAttributeNames;
 
 		/**
 		 * The list of attribute names to request for receiveMessage calls.
 		 */
+		@Nullable
 		private List<String> attributeNames;
 
+		@Nullable
+		public Boolean getEnabled() {
+			return enabled;
+		}
+
+		public void setEnabled(Boolean enabled) {
+			this.enabled = enabled;
+		}
+
+		@Nullable
 		public Integer getMaxNumberOfMessages() {
 			return maxNumberOfMessages;
 		}
@@ -189,6 +220,7 @@ public void setMaxNumberOfMessages(Integer maxNumberOfMessages) {
 			this.maxNumberOfMessages = maxNumberOfMessages;
 		}
 
+		@Nullable
 		public Duration getSendBatchFrequency() {
 			return sendBatchFrequency;
 		}
@@ -197,6 +229,7 @@ public void setSendBatchFrequency(Duration sendBatchFrequency) {
 			this.sendBatchFrequency = sendBatchFrequency;
 		}
 
+		@Nullable
 		public Duration getVisibilityTimeout() {
 			return visibilityTimeout;
 		}
@@ -205,6 +238,7 @@ public void setVisibilityTimeout(Duration visibilityTimeout) {
 			this.visibilityTimeout = visibilityTimeout;
 		}
 
+		@Nullable
 		public Duration getWaitTimeSeconds() {
 			return waitTimeSeconds;
 		}
@@ -213,6 +247,7 @@ public void setWaitTimeSeconds(Duration waitTimeSeconds) {
 			this.waitTimeSeconds = waitTimeSeconds;
 		}
 
+		@Nullable
 		public List<MessageSystemAttributeName> getSystemAttributeNames() {
 			return systemAttributeNames;
 		}
@@ -221,6 +256,7 @@ public void setSystemAttributeNames(List<MessageSystemAttributeName> systemAttri
 			this.systemAttributeNames = systemAttributeNames;
 		}
 
+		@Nullable
 		public List<String> getAttributeNames() {
 			return attributeNames;
 		}