tests/MassTransit.Tests/MessageData/ResponseMessageData_Specs.cs - develop - vshmidt/masstransit

tests/MassTransit.Tests/MessageData/ResponseMessageData_Specs.cs

82 строки2 KB

Chris Patterson

Clean up Roslyn errors in test projects from NUnit Analyzer

14 ноя 2024, 17:30

14 ноя 2024, 17:30eed50ef

namespace MassTransit.Tests.MessageData
{
    using System;
    using System.Threading.Tasks;
    using MassTransit.MessageData.Configuration;
    using NUnit.Framework;
    using TestFramework;


    [TestFixture]
    public class Sending_a_request_with_response_message_data :
        InMemoryTestFixture
    {
        [Test]
        public async Task Should_load_the_data_from_the_repository()
        {
            IRequestClient<Request> client = CreateRequestClient<Request>();

            Response<Response> response = await client.GetResponse<Response>(new
            {
                InVar.CorrelationId,
                Key = "Hello"
            });

            await Assert.MultipleAsync(async () =>
            {
                Assert.That(response.Message.Key, Is.EqualTo("Hello"));

                Assert.That(await response.Message.Value.Value, Is.Not.Empty);
            });
        }

        [Test]
        public async Task Should_load_the_data_from_the_repository_via_connect()
        {
            IRequestClient<Request> client = await ConnectRequestClient<Request>();

            Response<Response> response = await client.GetResponse<Response>(new
            {
                InVar.CorrelationId,
                Key = "Hello"
            });

            Assert.That(await response.Message.Value.Value, Is.Not.Empty);
        }

        protected override void ConfigureInMemoryBus(IInMemoryBusFactoryConfigurator configurator)
        {
            configurator.UseRetry<Response>(r => r.Immediate(1));

            configurator.UseMessageData(x => x.InMemory());
        }

        protected override void ConfigureInMemoryReceiveEndpoint(IInMemoryReceiveEndpointConfigurator configurator)
        {
            configurator.UseMessageRetry(r => r.None());

            _ = Handler<Request>(configurator, async context =>
            {
                await context.RespondAsync<Response>(new
                {
                    context.Message.Key,
                    Value = "This is a huge string, and it is just too big to fit."
                });
            });
        }


        public interface Request
        {
            Guid CorrelationId { get; }
            string Key { get; }
        }


        public interface Response
        {
            string Key { get; }
            MessageData<string> Value { get; }
        }
    }
}