in scenarios/aca-internal/bicep/sample-apps/jobs/src/aca-jobs/MessageProcessor.cs [25:37]
public async Task ExecuteAsync(CancellationToken stoppingToken)
{
_logger.LogInformation("Processor running at: {time}", DateTimeOffset.Now);
var numbers = await _receiver.ReceiveNumbersAsync(_settings.FetchCount, TimeSpan.FromMinutes(_settings.MaxWaitTime),
stoppingToken);
foreach (var n in numbers)
{
await _sender.SendMessageAsync(
new ServiceBusMessage(Fibonacci(n).ToString()), stoppingToken);
}
}