MassTransit - 对大型有效负载消费者进行单元测试答案

【问题标题】：MassTransit - Unit Testing a Large Payload ConsumerMassTransit - 对大型有效负载消费者进行单元测试
【发布时间】：2019-05-19 07:54:55
【问题描述】：

使用 InMemoryTestHarness，我正在对处理具有 MessageData 属性的命令的消费者进行单元测试。使用 InMemoryMessageDataRepository 填充 MessageData 属性可以正常工作，但是，当消费者尝试加载有效负载 (message.Body.Value) 时，我收到以下异常：“未加载消息数据：urn:msgdata:xxxxxxxxxxxxxxxxxxxxxxxxxx”}。对使用 MessageData 属性处理命令的消费者进行单元测试的正确方法是什么？

我打算使用内存中传输，但这似乎不是正确的方法，因为单元测试不会立即收到消费者的反馈。最终目标是让我的单元测试能够断言特定异常被抛出或消费者成功完成而没有错误。

using System;
using System.Linq;
using System.Threading.Tasks;
using MassTransit;
using MassTransit.MessageData;
using MassTransit.Testing;
using Newtonsoft.Json;
using Xunit;

namespace Test
{
    public class LargePayloadConsumerTest
    {
        [Fact]
        public async Task Consumer_Should_Deserialize_Message()
        {
            var harness = new InMemoryTestHarness();
            var consumer = harness.Consumer<BigMessageConsumer>();
            var command = new BigMessageCommand();
            var dataRepo = new InMemoryMessageDataRepository();

            var largePayload = new BigMessagePayload()
            {
                Id = 1,
                FirstName = "TestFirstName",
                MiddleName = "TestMiddleName",
                LastName = "TestLastName"
            };


            var json = JsonConvert.SerializeObject(largePayload);
            command.Body = await dataRepo.PutString(json);

            var thisWorks = await command.Body.Value;
            await harness.Start();
            await harness.InputQueueSendEndpoint.Send(command);

            Assert.True(harness.Consumed.Select<BigMessageCommand>().Any());
        }

        public class BigMessageConsumer : IConsumer<BigMessageCommand>
        {
            public async Task Consume(ConsumeContext<BigMessageCommand> context)
            {
                try
                {
                    var json = await context.Message.Body.Value;
                    var deserialized = JsonConvert.DeserializeObject<BigMessagePayload>(json);
                    Console.WriteLine($"{deserialized.Id}: {deserialized.FirstName} {deserialized.MiddleName} {deserialized.LastName}");
                }
                catch (Exception e)
                {
                    //throws {"The message data was not loaded: urn:msgdata:xxxxxxxxxxxxxxxxxxxxxxxxxx"}
                    Console.WriteLine(e);
                    throw;
                }
            }
        }

        public class BigMessageCommand
        {
            public MessageData<string> Body { get; set; }
        }

        public class BigMessagePayload
        {
            public int Id { get; set; }
            public string FirstName { get; set; }
            public string LastName { get; set; }
            public string MiddleName { get; set; }
        }
    }
}

【问题讨论】：

标签： c# masstransit

【解决方案1】：

你需要配置接收端点来处理消息数据属性，类似这样：

e.UseMessageData<BigMessageCommand>(dataRepo);

由于您正在使用测试工具，您可以在添加消费者测试工具之前将其添加到接收端点：

void ConfigureReceiveEndpoint(IReceiveEndpointConfigurator configurator)
{
    configurator.UseMessageData<BigMessageCommand>(dataRepo);
}

harness.OnConfigureReceiveEndpoint += ConfigureReceiveEndpoint;

【讨论】：