Send message to a queue or topic of Azure service bus

Prerequisites

Azure service bus and queue or topic need to be created on azure portal.

Step 1:

We need to install “Microsoft.Azure.ServiceBus” nuget package in our project.

Step 2:

We will create static method using which we can send message  to any queue or topic  from anywhere in the solution using this method.

So here is the code for that method:

using Microsoft.Azure.ServiceBus;

using Newtonsoft.Json;

using System;

using System.Reflection;

using System.Text;

namespace ServiceBusExample

{

    public class AzureServiceBusPublisher

    {

        private static readonly string ConnectionString = “enter your service bus connection string here”;

        private static IQueueClient _queueClient { get; set; }

        private static ITopicClient _topicClient;

        public static void Publish<T>(T message, string name, ClientType clientType)

        {

            var serializedMessage = JsonConvert.SerializeObject(message);

            var m = new Message(Encoding.UTF8.GetBytes(serializedMessage))

            {

                ContentType = "application/json"

            };

            try

            {

                LogServices.LogInformation(new LogEntry(MethodBase.GetCurrentMethod())

                {

                    Message = $"Publishing message to Azure Service bus. MessageContent: {serializedMessage}"

                });

                if (clientType == ClientType.Queue)

                {

                    _queueClient = new QueueClient(ConnectionString, name);

                    _queueClient.SendAsync(m).GetAwaiter().GetResult();

                }

                if (clientType == ClientType.Topic)

                {

                    _topicClient = new TopicClient(ConnectionString, name);

                    _topicClient.SendAsync(m).GetAwaiter().GetResult();

                }

            }

            catch (Exception ex)

            {

                // log error

            }

        }

    }

    public enum ClientType

    {

        Queue,

        Topic

    }

}

Step 3:

Now we can us method anywhere in the solution. This is an example how we will call this method.

AzureServiceBusPublisher.Publish(model, queueName, ClientType.Queue);

This method has three parameters. In first parameter we can pass any strongly type model. In second parameter we have to pass queue or topic name. And third parameter is for client type.

TIP: PowerShell script to run all SQL scripts in a folder and in subfolders

You can simply open the “Windows powerShell ISE”.

paste the below script and update the variables as per your folder and SQL details. You need to update ServerName, DatabaseName,"UserName","Password" and Folder Path.

 #Provide SQLServerName
 $ServerName ="ServerName"
 #Provide SQLServerName  
 $ServerName ="ServerName"  
 #Provide Database Name  
 $DatabaseName ="DatabaseName"  
 #Provide Login UserName  
 $UserName = "sa"  
 #Provide Login Password  
 $Password = "Password"  
 #Scripts Folder Path  
 $FolderPath ="E:\Workspace\SqlScripts \"  
 #Loop through the .sql files and run them  
 foreach ($filename in get-childitem -path $FolderPath -recurse -file -filter "*.sql" |  
 sort-object)  
 {  
 invoke-sqlcmd –ServerInstance $ServerName -Database $DatabaseName -Username $UserName -Password $Password -InputFile $filename.fullname  
 #Print file name which is executed  
 $filename  
 }  

And press run button it will execute all your scripts.