Hypothesist.MassTransit

Use Hypothesist to validate received messages as a MassTransit consumer.

Arrange

var message = new Message(1234); // <-- records are awesome!
var hypothesis = Hypothesis
    .For<Message>()
    .Any(x => x == message);

var bus = Bus.Factory
    .CreateUsingRabbitMq(cfg =>
    {
        cfg.ReceiveEndpoint("...", e =>
        {
            e.Consumer(hypothesis.AsConsumer);
        });
    });
await bus.StartAsync();

Act

var endpoint = await bus.GetPublishSendEndpoint<Message>();
await endpoint.Send(message);

Assert

await hypothesis.Validate(10.Seconds());