/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
tests/MassTransit.Azure.ServiceBus.Core.Tests/AzureServiceBusTestSetUpFixture.cs
55 строк
2 KB
Chris Patterson
Related to #3909 - moved extensions to Testing namespace, some others to Internals
09 дек 2022, 21:12
09 дек 2022, 21:12
261321d
Код
Авторство
О чём код?
using NUnit.Framework; [assembly: Parallelizable(ParallelScope.None)] [assembly: LevelOfParallelism(1)] namespace MassTransit.Azure.ServiceBus.Core.Tests { using System; using System.Threading.Tasks; using Internals; [SetUpFixture] public class AzureServiceBusTestSetUpFixture { [OneTimeSetUp] public async Task Before_any() { await CleanupNamespace(); } async Task CleanupNamespace() { try { var managementClient = Configuration.GetManagementClient(); var pageableTopics = managementClient.GetTopicsAsync(); var topics = await pageableTopics.ToListAsync(); while (topics.Count > 0) { foreach (var topic in topics) await managementClient.DeleteTopicAsync(topic.Name); topics = await managementClient.GetTopicsAsync().ToListAsync(); } var pageableQueues = managementClient.GetQueuesAsync(); var queues = await pageableQueues.ToListAsync(); while (queues.Count > 0) { foreach (var queue in queues) await managementClient.DeleteQueueAsync(queue.Name); queues = await managementClient.GetQueuesAsync().ToListAsync(); } } catch (Exception exception) { Console.WriteLine(exception); } } } }