Saga.cs

public class OrderSaga :
    Saga<OrderSagaData>,
    IAmStartedByMessages<PlaceOrder>,
    IHandleMessages<ProcessPayment>,
    IHandleMessages<EmailConfirmation>,
    IHandleTimeouts<CancelOrder>
{
    static readonly ILog Log = LogManager.GetLogger<OrderSaga>();

    protected override void ConfigureHowToFindSaga(SagaPropertyMapper<OrderSagaData> mapper)
    {
        mapper.MapSaga(sagaData => sagaData.OrderId)
            .ToMessage<PlaceOrder>(message => message.OrderId)
            .ToMessage<ProcessPayment>(message => message.OrderId)
            .ToMessage<EmailConfirmation>(message => message.OrderId);
    }

    public async Task Handle(PlaceOrder message, IMessageHandlerContext context)
    {
        Log.Info($"PlaceOrder received with OrderId {message.OrderId}");

        var timeout = DateTimeOffset.UtcNow.AddSeconds(5);
        Log.Info("Requesting a CancelOrder that will be executed in 5 seconds.");
        await RequestTimeout<CancelOrder>(context, timeout);

        var processPayment = new ProcessPayment
        {
            OrderId = Data.OrderId
        };
        await context.SendLocal(processPayment);
    }

    public async Task Handle(ProcessPayment message, IMessageHandlerContext context)
    {
        Data.PaymentProcessed = true;
        Log.Info($"ProcessPayment received with OrderId {message.OrderId}");

        var emailConfirmation = new EmailConfirmation
        {
            OrderId = Data.OrderId
        };
        await context.SendLocal(emailConfirmation);
    }

    public Task Handle(EmailConfirmation message, IMessageHandlerContext context)
    {
        Log.Info($"Email Confirmation received with OrderId {message.OrderId}");

        MarkAsComplete();

        Log.Info($"Process Complete for OrderId {message.OrderId}");

        return Task.CompletedTask;
    }

    public Task Timeout(CancelOrder state, IMessageHandlerContext context)
    {
        if (Data.PaymentProcessed)
        {
            Log.Info($"Cannot cancel order since payment has been processed for OrderId {Data.OrderId}.");
            return Task.CompletedTask;
        }

        Log.Info($"CompleteOrder not received soon enough OrderId {Data.OrderId}.");

        MarkAsComplete();

        Log.Info($"Process Complete for OrderId {Data.OrderId}");

        return Task.CompletedTask;
    }
}