我正在为我的项目进行集成测试。我已经容器化了RabbitMQ队列,容器化了这个队列的消费者(使用MassTransit),容器化了这个消费者在消息处理过程中调用的API。我的测试将消息推送到队列,它被使用者拾取,这就是我的问题所在-从我的测试Angular 来看,是否有方法检查容器内的使用者何时处理消息?现在我只使用Thread.Sleep() 10秒,然后运行Assert。它工作正常,但是,很明显,随着测试数量的增长,这变得越来越乏味...
Thread.Sleep()
fv2wmkja1#
也许这个能帮你https://event-driven.io/en/testing_asynchronous_processes_with_a_little_help_from_dotnet_channels/允许等待来自测试内部的rabbitmq事件,而无需执行线程。
1条答案
按热度按时间fv2wmkja1#
也许这个能帮你
https://event-driven.io/en/testing_asynchronous_processes_with_a_little_help_from_dotnet_channels/
允许等待来自测试内部的rabbitmq事件,而无需执行线程。