我正在尝试围绕我使用 MassTransit 创建的一些服务创建黑盒集成测试。该服务的要点是它在 MassTransit channel 上接收消息,处理消息并在不同的 MassTransit channel 上发送消息(请注意,这不是请求-回复语义,而是管道中的一个组件):
IBusControl bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
{
var host = cfg.Host(new Uri("rabbitmq://localhost"),
h =>
{
h.Username("guest");
h.Password("guest");
});
cfg.ReceiveEndpoint(host, "Queue1", ep =>
{
ep.Handler<ItemStarted>(context =>
{
ItemFinished item = FinishMessage(context.Message);
context.Publish(item);
});
});
});
bus.Start();
为了对此进行测试,我认为我需要一种从总线接收消息的同步方式。有什么办法可以做到这一点:
IBusControl bus = Bus.Factory.CreateUsingRabbitMq(cfg =>
var host = cfg.Host(new Uri("rabbitmq://localhost"),
h =>
{
h.Username("guest");
h.Password("guest");
}));
bus.Start();
bus.Publish(new ItemStarted());
// This is what does not seem to exist
ItemFinished finished = bus.Receive<ItemFinished>(timeout : Timespan.FromSeconds(5));
// Assertions about finished
有没有一种方法可以直接从 MassTransit 接收消息,而无需连接消费者类或 lambda?
最佳答案
MultiTestConsumer
可用于接收和跟踪测试期间产生的消息。你可以在这里看到这个类:
https://github.com/MassTransit/MassTransit/blob/develop/src/MassTransit/Testing/MultiTestConsumer.cs
你可以在这里看到它是如何使用的:
它也可以用作常规的订阅消费者,它在 RabbitMQ 中设置绑定(bind)以接收发布的消息。
我建议查看 TestFramework,因为那里有很多异步测试助手。
关于c# - 使用 MassTransit 集成测试微服务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/33336808/