MassTransit & RabbitMQ -如何验证消息在集装箱化的消费者内部得到处理?

niknxzdl  于 2023-01-09  发布在  RabbitMQ
关注(0)|答案(1)|浏览(154)

我正在为我的项目进行集成测试。我已经容器化了RabbitMQ队列,容器化了这个队列的消费者(使用MassTransit),容器化了这个消费者在消息处理过程中调用的API。
我的测试将消息推送到队列,它被使用者拾取,这就是我的问题所在-从我的测试Angular 来看,是否有方法检查容器内的使用者何时处理消息?
现在我只使用Thread.Sleep() 10秒,然后运行Assert。它工作正常,但是,很明显,随着测试数量的增长,这变得越来越乏味...

相关问题