in scenarios/aca-internal/bicep/sample-apps/jobs/src/aca-jobs/MessageReceiver.cs [24:40]
public async Task ExecuteAsync(CancellationToken stoppingToken)
{
_logger.LogInformation("Receiver running at: {time}", DateTimeOffset.Now);
try
{
var numbers = await _receiver.ReceiveNumbersAsync(_settings.FetchCount,
TimeSpan.FromSeconds(_settings.MaxWaitTime), stoppingToken);
_logger.LogInformation("Received {Count} messages from the {Name} queue",
numbers.Count, _settings.OutputQueueName);
_logger.LogInformation("The numbers are: {Numbers}", string.Join(", ", numbers));
}
catch (Exception e)
{
_logger.LogError("An error occurred while receiving messages from the {Name} queue: {Error}",
_settings.OutputQueueName, e.Message);
}
}