diff --git a/testkit/src/main/scala/com/commercetools/queue/testkit/QueueSubscriberSuite.scala b/testkit/src/main/scala/com/commercetools/queue/testkit/QueueSubscriberSuite.scala index c3f5359..466eeb2 100644 --- a/testkit/src/main/scala/com/commercetools/queue/testkit/QueueSubscriberSuite.scala +++ b/testkit/src/main/scala/com/commercetools/queue/testkit/QueueSubscriberSuite.scala @@ -13,6 +13,7 @@ import scala.concurrent.duration._ * implemented for a concrete client. */ trait QueueSubscriberSuite extends CatsEffectSuite { self: QueueClientSuite => + val waitingTime: FiniteDuration = 20.seconds withQueue.test("puller returns no messages if none is available during the configured duration") { queueName => val client = clientFixture()