in scenarios/aca-internal/bicep/sample-apps/jobs/src/aca-jobs/SBHelper.cs [60:80]
public static async Task SendNumberListAsync(this ServiceBusSender sender, ConfigurationOptions configuration,
ILogger logger, CancellationToken stoppingToken)
{
List<ServiceBusMessage> messages = new();
for (int i = 0; i < configuration.MessageCount; i++)
{
messages.Add(new ServiceBusMessage(
$"{new Random().Next(configuration.MinNumber, configuration.MaxNumber)}"));
}
try
{
await sender.SendMessagesAsync(messages, stoppingToken);
logger.LogInformation("Sent a list of {Count} messages to the {Name} queue",
configuration.MessageCount, configuration.InputQueueName);
}
catch (Exception e)
{
logger.LogError("An error occurred while sending messages to the {Name} queue: {Error}",
configuration.InputQueueName, e.Message);
}
}