Purge queue#
Полезные ссылки:
import static ru.tinkoff.qa.neptune.rabbit.mq.RabbitMqStepContext.rabbitMq;
public class MyTest {
@Test
public void myTest() {
//Выполняем очистку содержимого очереди
rabbitMq().purgeQueue("queue");
}
}
import static ru.tinkoff.qa.neptune.rabbit.mq.RabbitMqStepContext.rabbitMq;
public class MyTest {
@Test
public void myTest() {
//в качестве имени очереди используется
//значение RABBIT_MQ_DEFAULT_QUEUE_NAME
rabbitMq().purgeQueue();
}
}