Fail at startup if queues are not the same type for a container

spring-cloud-aws-sqs/src/main/java/io/awspring/cloud/sqs/listener/SqsMessageListenerContainer.java

@@ -122,14 +122,15 @@ public SqsMessageListenerContainer(SqsAsyncClient sqsAsyncClient) {
 
 	@Override
 	protected Collection<ContainerComponentFactory<T, SqsContainerOptions>> createDefaultComponentFactories() {
-		Assert.isTrue(allQueuesSameType(),
-				"SqsMessageListenerContainer must contain either all FIFO or all Standard queues.");
 		return Arrays.asList(new FifoSqsComponentFactory<>(), new StandardSqsComponentFactory<>());
 	}
 
-	private boolean allQueuesSameType() {
-		return getQueueNames().stream().allMatch(this::isFifoQueue)
-				|| getQueueNames().stream().noneMatch(this::isFifoQueue);
+	@Override
+	public void setQueueNames(Collection<String> queueNames) {
+		Assert.isTrue(
+			queueNames.stream().allMatch(this::isFifoQueue) || queueNames.stream().noneMatch(this::isFifoQueue),
+			"SqsMessageListenerContainer must contain either all FIFO or all Standard queues.");
+		super.setQueueNames(queueNames);
 	}
 
 	private boolean isFifoQueue(String name) {

spring-cloud-aws-sqs/src/test/java/io/awspring/cloud/sqs/listener/SqsMessageListenerContainerTests.java

@@ -185,4 +185,14 @@ void shouldNotThrowIfProperCustomExecutorAckResult() {
 		container.stop();
 	}
 
+	@Test
+	void shouldThrowIfMixedQueueTypes() {
+		SqsAsyncClient client = mock(SqsAsyncClient.class);
+		SqsMessageListenerContainer.Builder<Object> builder = SqsMessageListenerContainer.builder()
+				.sqsAsyncClient(client).queueNames("queue", "queue.fifo");
+
+		assertThatThrownBy(builder::build).isInstanceOf(IllegalArgumentException.class)
+				.hasMessageContaining("must contain either all FIFO or all Standard queues");
+	}
+
 }