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 = c + 1;

                var messageForClientId = m + 1;

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

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

                var message = new ServiceBusMessage(messageId);

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

                message.ApplicationProperties.Add("TaxCode", "IL");

                message.ApplicationProperties.Add("Quarter", 1);

                message.ApplicationProperties.Add("CreditAmount", 100.00);

                message.ApplicationProperties.Add("checkYear", 2023);

                message.ApplicationProperties.Add("ClientTaxUid", "280447597422856     ");

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

                messagesForClient.Add(message);

            }

​

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

            {

                await sender.SendMessagesAsync(batch);

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

            }

        }

    }   

}