Rebus timeout example

gistfile1.cs

These two can be in the same handler:

public void Handle(SomethingInteresting msg)
{
    var correlationId = "possiblySomethingThatMakesSense";
    bus.Send(new SomeMessageThatKicksOffSomeProcess { CorrelationId = correlationId });
    bus.Defer(TimeSpan.FromMinutes(2), new VerifyThatAllExpectedRepliesWereReceived { CorrelationId = correlationId });
}

public void Handle(VerifyThatAllExpectedRepliesWereReceived msg)
{
    var correlationId = msg.CorrelationId;

    // check whether process was completed for something that we can identify via the correlation ID

    // send emails, perform compensating actions, etc
}