wait after publishing messages

commercetools · Oct 23, 2024 · 3a72e35 · 3a72e35
1 parent f818d3a
commit 3a72e35
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/testkit/src/main/scala/com/commercetools/queue/testkit/QueueSubscriberSuite.scala b/testkit/src/main/scala/com/commercetools/queue/testkit/QueueSubscriberSuite.scala
@@ -155,6 +155,7 @@ trait QueueSubscriberSuite extends CatsEffectSuite { self: QueueClientSuite =>
           .through(client.publish(queueName).sink(batchSize = totalMessages))
           .compile
           .drain
+        _ <- IO.sleep(3.seconds)
         msgBatch <- puller.pullMessageBatch(totalMessages, waitingTime)
         _ = assertEquals(msgBatch.messages.size, totalMessages)
         _ <- msgBatch.nackAll