diff --git a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitMultiBinderObservationTests.java b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitMultiBinderObservationTests.java index ae4fc13f1..c9c3e8e16 100644 --- a/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitMultiBinderObservationTests.java +++ b/binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/integration/RabbitMultiBinderObservationTests.java @@ -84,7 +84,7 @@ public class RabbitMultiBinderObservationTests { // There is a race condition when we already have a reply, but the span in the // Rabbit listener is not closed yet. // parent -> StreamBridge -> RabbitTemplate -> Rabbit Listener -> Consumer - await().untilAsserted(() -> assertThat(SPANS.spans()).hasSize(5)); + await().untilAsserted(() -> assertThat(SPANS.spans()).hasSize(6)); SpansAssert.assertThat(SPANS.spans().stream().map(BraveFinishedSpan::fromBrave).collect(Collectors.toList())) .haveSameTraceId(); }