diff --git a/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/config/SqsMessageListenerContainerFactory.java b/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/config/SqsMessageListenerContainerFactory.java index 1b335b3c4..e2f9f4902 100644 --- a/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/config/SqsMessageListenerContainerFactory.java +++ b/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/config/SqsMessageListenerContainerFactory.java @@ -66,7 +66,7 @@ * beans implementing these interfaces will be set to the default factory. *
* Example using the builder: - * + * *
*
* @Bean
@@ -74,7 +74,7 @@
* return SqsMessageListenerContainerFactory
* .builder()
* .configure(options -> options
- * .messagesPerPoll(5)
+ * .maxMessagesPerPoll(5)
* .pollTimeout(Duration.ofSeconds(10)))
* .sqsAsyncClient(sqsAsyncClient)
* .build();
@@ -84,7 +84,7 @@
*
*
* Example using the default constructor:
- *
+ *
*
*
* @Bean
@@ -92,7 +92,7 @@
* SqsMessageListenerContainerFactory
*
* Example creating a container manually:
- *
+ *
*
*
* @Bean
@@ -108,11 +108,11 @@
* return SqsMessageListenerContainerFactory
* .builder()
* .configure(options -> options
- * .messagesPerPoll(5)
+ * .maxMessagesPerPoll(5)
* .pollTimeout(Duration.ofSeconds(10)))
* .sqsAsyncClient(sqsAsyncClient)
* .build()
- * .create("myQueue");
+ * .createContainer("myQueue");
* }
*
*
diff --git a/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/SqsMessageListenerContainer.java b/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/SqsMessageListenerContainer.java
index 1bfcc4308..52650e5d7 100644
--- a/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/SqsMessageListenerContainer.java
+++ b/spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/SqsMessageListenerContainer.java
@@ -60,7 +60,7 @@
* manually and declared as beans will have their lifecycle managed by Spring Context.
*
* Example using the builder:
- *
+ *
*
*
* @Bean
@@ -68,9 +68,11 @@
* return SqsMessageListenerContainer
* .builder()
* .configure(options -> options
- * .messagesPerPoll(5)
+ * .maxMessagesPerPoll(5)
* .pollTimeout(Duration.ofSeconds(10)))
* .sqsAsyncClient(sqsAsyncClient)
+ * .messageListener(System.out::println)
+ * .queueNames("myTestQueue")
* .build();
* }
*
@@ -78,15 +80,17 @@
*
*
* Example using the constructor:
- *
+ *
*
*
* @Bean
* public SqsMessageListenerContainer