using System;

using System.Threading.Tasks;

using Azure.Messaging.ServiceBus;

using System.Collections.Generic;

using System.Linq;

public class Program

{

    public static async Task Main()

    {

        await QueueMessagesAsync();

    }

    public static async Task QueueMessagesAsync() 

    {

        var serviceBusConnectionString = "Endpoint=sb://nen040722-solids-sb-local-dev.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=yaOc0Xz7/U4DQWhgZREW4sgdJlMiNnl3c+ASbGtw5CA=";

        var serviceBusClient = new ServiceBusClient(serviceBusConnectionString);

        var sender = serviceBusClient.CreateSender("tax");

​

​

        int numberOfClients = 1;//500;

        int numberOfMessagesPerClient = 1;//3;

        int numberOfMessagesPerBatch = 50;

​

        for (int c = 0; c < numberOfClients; c++)

        {

            var messagesForClient = new List<ServiceBusMessage>();

            for (int m = 0; m < numberOfMessagesPerClient; m++)

            {

                var clientId = 297045; // 162314, 300365

                var dateTime = $"{DateTime.UtcNow.ToString("o")}";

                var messageId = $"{clientId}-{dateTime}";

                var message = new ServiceBusMessage(messageId);

​

                message.ApplicationProperties.Add("CG_Name", "ClientTaxCode");

                message.ApplicationProperties.Add("ClientId", 297045);

                message.ApplicationProperties.Add("TaxAuthCode", "OHLAN");

                messagesForClient.Add(message);

            }

​

            foreach (var batch in messagesForClient.Chunk(numberOfMessagesPerBatch))

            {

                await sender.SendMessagesAsync(batch);

                Console.WriteLine($"Sent {batch.Count()} messages");

            }

        }

    }   

}