Technical Support and Solutions: Publish messages to Azure Service Bus using c# console app.

In this article, I will explain and provide the working code to pusblish message to Azure service bus using C# console app.

First of all install the Server Bus package and include below ref

using Azure.Messaging.ServiceBus;

Define service bus connection string and queue name

private const string serviceBusConnectionString = "Copy and paste service bus connection string";

private const string queueName = "demo-servicebusqueue";

Define variables to use

private const int numOfMessages = 200;

static ServiceBusClient client = default!;

static ServiceBusSender sender = default!;

static ServiceBusProcessor processor = default!;

Below is the main method calls Message publisher method which generates message and push to service bus

public static async Task Main(string[] args)

{

try

{

await MessagePublisher();

}

catch (Exception ex)

{

Console.WriteLine($"Exception: {ex.Message}");

}

Define publisher method, in this case, which generates message

private static async Task<string> MessagePublisher()

{

// create service bus client

client = new ServiceBusClient(serviceBusConnectionString);

// Create message sender

sender = client.CreateSender(queueName);

// create service message batch

using ServiceBusMessageBatch messageBatch = await sender.CreateMessageBatchAsync();

var msg = "";

for (int i =1; i <= numOfMessages; i++)

{

msg= $"{{\"id\": {i},\"createdOn\": \"2023-04-05T13:04:57\",\"description\": \"This is very good product with 1 year wanranty\",\"isDone\": false}}";

// add message to batch

if (!messageBatch.TryAddMessage(new ServiceBusMessage(msg)))

{

throw new Exception($"An exception has been thrown");

}

try

{

// finally send message to azure service bus

await sender.SendMessagesAsync(messageBatch);

Console.WriteLine($"A batch of {numOfMessages} messages has been published to the queue.");

}

finally

{

await sender.DisposeAsync();

await client.DisposeAsync();

}

return "All messages have been published to the queue";

}

Complete code

using System;

using System.Diagnostics;

using System.Threading.Tasks;