NServiceBus scheduler alternative - NServiceBus V6 & NServiceBus.Host V7

self-hosting.cs

var endpointInstance = await Endpoint.Start(endpointConfiguration).ConfigureAwait(false);


// Send a message every 30 seconds
var cancellationTokenSource = new CancellationTokenSource();
var loop = Task.Run(async () =>
{
    while (!cancellationTokenSource.IsCancellationRequested)
    {
        try
        {
            await endpointInstance.SendLocal(new DoSomething()).ConfigureAwait(false);
            await Task.Delay(TimeSpan.FromSeconds(30), cancellationTokenSource.Token).ConfigureAwait(false);
        }
        catch (Exception ex) // Also catches OperationCanceledException, no issue as while loop is testing on cancellation
        {
            log.Error("Failure sending DoSomething", ex);
        }
    }
});


// Before await endpointInstance.Stop()
cancellationTokenSource.Cancel();
await loop.ConfigureAwait(false);

SendDoSomethingTask.cs

public class SendDoSomethingTask : IWantToRunWhenEndpointStartsAndStops
{
    ILog log = LogManager.GetLogger<SendDoSomethingTask>();
    Task loop;
    CancellationTokenSource cancellationTokenSource;

    public Task Start(IMessageSession session)
    {
        cancellationTokenSource = new CancellationTokenSource();
        loop = Task.Run(async () =>
        {
            while (!cancellationTokenSource.IsCancellationRequested)
            {
                try
                {
                    await session.SendLocal(new DoSomething()).ConfigureAwait(false);
                    await Task.Delay(TimeSpan.FromSeconds(5), cancellationTokenSource.Token).ConfigureAwait(false);
                }
                catch (Exception ex) // Also catches OperationCanceledException, no issue as while loop is testing on cancellation
                {
                    log.Error("Failure sending DoSomething", ex);
                }
            }
        }        );
        return Task.CompletedTask;
    }

    public async Task Stop(IMessageSession session)
    {
        cancellationTokenSource.Cancel();
        await loop.ConfigureAwait(false);
    }
}