diff --git a/spring-rabbitmq-client/src/test/java/org/springframework/amqp/rabbitmq/client/listener/RabbitAmqpListenerTests.java b/spring-rabbitmq-client/src/test/java/org/springframework/amqp/rabbitmq/client/listener/RabbitAmqpListenerTests.java
index 816756fd..7d286157 100644
--- a/spring-rabbitmq-client/src/test/java/org/springframework/amqp/rabbitmq/client/listener/RabbitAmqpListenerTests.java
+++ b/spring-rabbitmq-client/src/test/java/org/springframework/amqp/rabbitmq/client/listener/RabbitAmqpListenerTests.java
@@ -170,7 +170,7 @@ class RabbitAmqpListenerTests extends RabbitAmqpTestBase {
 
 		final List<String> received = Collections.synchronizedList(new ArrayList<>());
 
-		CountDownLatch consumeIsDone = new CountDownLatch(10);
+		CountDownLatch consumeIsDone = new CountDownLatch(11);
 
 		@RabbitListener(queues = {"q1", "q2"},
 				ackMode = "#{T(org.springframework.amqp.core.AcknowledgeMode).MANUAL}",