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 factory = new SqsMessageListenerContainerFactory<>();
  *     factory.setSqsAsyncClient(sqsAsyncClient);
  *     factory.configure(options -> options
- *             .messagesPerPoll(5)
+ *             .maxMessagesPerPoll(5)
  *             .pollTimeout(Duration.ofSeconds(10)));
  *     return factory;
  * }
@@ -100,7 +100,7 @@
  * 
  * 

* 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 myListenerContainer(SqsAsyncClient sqsAsyncClient) {
  *     SqsMessageListenerContainer container = new SqsMessageListenerContainer<>(sqsAsyncClient);
  *     container.configure(options -> options
- *             .messagesPerPoll(5)
+ *             .maxMessagesPerPoll(5)
  *             .pollTimeout(Duration.ofSeconds(10)));
+ *     container.setQueueNames("myTestQueue");
+ *     container.setMessageListener(System.out::println);
  *     return container;
  * }
  *