NServiceBus - Report processing durations for failed messages

ReportFailedDurationsBehavior.cs

//
//  endpointConfiguration.Pipeline.Register(new ReportFailedDurationsBehavior(), nameof(ReportFailedDurationsBehavior));
//
class ReportFailedDurationsBehavior : IBehavior<IIncomingLogicalMessageContext, IIncomingLogicalMessageContext>
{
    static readonly ILog Log = LogManager.GetLogger(typeof(ReportFailedDurationsBehavior));
    static readonly bool IsDebugEnabled = Log.IsDebugEnabled;

    static readonly TimeSpan WarningThreshold = TimeSpan.FromSeconds(30);

    public async Task Invoke(IIncomingLogicalMessageContext context, Func<IIncomingLogicalMessageContext, Task> next)
    {
        var start = Stopwatch.StartNew();
        try
        {

            await next(context).ConfigureAwait(false);
        }
        catch
        {
            var duration = start.Elapsed;

            if (WarningThreshold > duration)
            {
                Log.WarnFormat("{0}: Failed after a processing duration {1} exceeds configured warning threshold ({2})", context.MessageId, duration, WarningThreshold);
            }

            if (IsDebugEnabled)
            {
                Log.DebugFormat("{0}: Failed after a processing duration {1}", context.MessageId, duration);
            }
            throw;
        }
    }
}