diff --git a/spring-boot-examples/pubsub/producer-app/src/test/java/io/dapr/springboot/examples/producer/ProducerAppIT.java b/spring-boot-examples/pubsub/producer-app/src/test/java/io/dapr/springboot/examples/producer/ProducerAppIT.java index b6c464b26b..61047d4c71 100644 --- a/spring-boot-examples/pubsub/producer-app/src/test/java/io/dapr/springboot/examples/producer/ProducerAppIT.java +++ b/spring-boot-examples/pubsub/producer-app/src/test/java/io/dapr/springboot/examples/producer/ProducerAppIT.java @@ -62,6 +62,9 @@ void setUp() { org.testcontainers.Testcontainers.exposeHostPorts(8080); DaprWait.forSubscription("pubsub", "topic").waitUntilReady(daprContainer); + // "topic" is declarative and is listed before daprd sees the app as healthy. "outbox-topic" comes + // from the app, so it is listed only once daprd starts subscribing, including to the outbox topic. + DaprWait.forSubscription("pubsub", "outbox-topic").waitUntilReady(daprContainer); } @AfterEach