test

commercetools · Oct 23, 2024 · 462b752 · 462b752
1 parent f396139
commit 462b752
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
@@ -85,6 +85,7 @@ trait QueueSubscriberSuite extends CatsEffectSuite { self: QueueClientSuite =>
       messages <- randomMessages(10)
       received <- Ref[IO].of(List.empty[(String, Map[String, String])])
       client = clientFixture()
+      _ <- assertIO(client.administration.exists(queueName), true)
       _ <- Stream
         .emits(messages)
         .through(client.publish(queueName).sink(batchSize = 10))