XML Serializer sample

var endpointConfiguration = new EndpointConfiguration("Samples.Serialization.Xml");

endpointConfiguration.UseSerialization<XmlSerializer>();

// Then later get it from the service provider when needed
builder.Services.AddSingleton<MessageBodyWriter>();
var serviceProvider = builder.Services.BuildServiceProvider();
var messageBodyWriter = serviceProvider.GetRequiredService<MessageBodyWriter>();

// register the mutator so the the message on the wire is written
endpointConfiguration.RegisterMessageMutator(messageBodyWriter);

public class MessageBodyWriter(ILogger<MessageBodyWriter> logger) :
    IMutateIncomingTransportMessages
{
    public Task MutateIncoming(MutateIncomingTransportMessageContext context)
    {
        var bodyAsString = Encoding.UTF8.GetString(context.Body.ToArray());

        logger.LogInformation("Serialized Message Body:");
        logger.LogInformation(bodyAsString);

        return Task.CompletedTask;
    }
}

var message = new CreateOrder
{
    OrderId = 9,
    Date = DateTime.Now,
    CustomerId = 12,
    OrderItems = new List<OrderItem>
{
    new OrderItem
    {
        ItemId = 6,
        Quantity = 2
    },
    new OrderItem
    {
        ItemId = 5,
        Quantity = 4
    },
}
};

await messageSession.SendLocal(message);