Microsoft Message Queuing(MSMQ) in Asp.net

The Name Microsoft Message Queue itself suggests the messages are stored in Queue either in your computer or in another computer waiting patiently for you to fetch the data from them. You can use Microsoft message queuing to reliably send messages from one computer to another Computer.

In this Modern era every public and private sector is computerised.For example a bank that has got multiple branches. The Bank Branches will store all the transaction data in their branch local Database and as well as central database .So that all the information is located at centralised location.whatever be the reason the central server fails so they can not able to store the transaction data on the centralized server.Will the Bank Branch Manager order their employees to stop all the transactions for the day or even until the central server is online ? Or he manually insert the data in the centralised server when its status changed to online.

The Answer is no he require his application to tackle this type of problem in such a way that he wants to store the data in a temporary location whenever Central database server comes to online the temporary location stored data moves in to the Central database. Now above scenario is apt to our topic. Message queues are particularly used for these types of scenarios

How to install Message Queues

Message queue is a Microsoft windows component. So first of all you need to add this component in your computer to test whether your sending message reaches to your msmq.

The below steps you need to follow to install Microsoft Message queues in Windows xp operating system

1) click Add/Remove Windows components

2)see After Management and Monitoring tools there is a component called Message queuing which is unchecked make it checked and click next to install your computer.

3) After configuring to your computer test whether the component is successfully installed in your computer or Not.

4)for that Go to Administrative tools - click Computer Management- services and Applications - Message Queuing

5) If not installed please contact your system Administrator..


Microsoft message queuing has Mainly two types of queues

1)Public Queue

2)Private Queue

Public Queues are available to application on every server in a Domain

Private Queues are available only to application on the local server

So this is the brief Introduction of Queues.

First Sample Program with Public Queues Retrieving the list of queues

First we need to import the name space System.Messaging

Dgrdqueues.DataSource = MessageQueue.GetPublicQueues();

If ! MessageQueue.Exists(“.\OrderQueue") 
MessageQueue.Create(“.\OrdersQueue")

If(! MessageQueue.Exists(“. \ Private$\PrivateOrders"))
{
   MessageQueue.Create(“. \ Private$\PrivateOrders")
}

 MessageQueues mqmessages =new MessageQueues();
If (!MessageQueue.Exists(“.\myQueue")
{
  mqmessages.Create(“.\myQueue	");
}
Mqmessages =new MessageQueue(“.\myqueue");
Mqmessages.send(“yourmessagebody",messagelabel)

Public class Products
{
Public string productname{get;set;}
Public int unitprice {get;set;}
Public int quantity{get;set;}
Public datetime Entrydate{get;set;}
Public list {get;set;}
}

Messagequeue msmq =new Messagequeue(“.\ProductOrders");
Products ObjProducts =new Products();
List lstprod=null; 
lstprod =new List();
ObjProducts.Prodcutname="Pen"
ObjProducts.unitprice=20
ObjProducts.quantity=5
ObjProducts.Entrydate =system,datetime.now();
Lstproduct.add(Objproducts);
Msmq.send(lstproducts,"product Order");
}

        public void SendMessage()
        {
						
            // Connect to a queue on the local computer.
            MessageQueue myQueue = new MessageQueue(".\\myQueue");

            // Send a message to the queue. 
            if (myQueue.Transactional == true)
            {
                // Create a transaction.
                MessageQueueTransaction myTransaction = new 
                    MessageQueueTransaction();

                // Begin the transaction.
                myTransaction.Begin();

                // Send the message.
                myQueue.Send("My Message Data.", myTransaction);

                // Commit the transaction.
                myTransaction.Commit();
            }
            else
            {
                myQueue.Send("My Message Data.");
            }

            return;
        }
    }
}

public   void ReceiveMessage()
		{
			// Connect to the a queue on the local computer.
			MessageQueue myQueue = new MessageQueue(".\\myQueue");

			// Set the formatter to indicate body contains an Order.
			myQueue.Formatter = new XmlMessageFormatter(new Type[]
				{typeof(MyProject.Order)});
			
			try
			{
				// Receive and format the message. 
				Message myMessage =	myQueue.Receive(); 
				Order myOrder = (Order)myMessage.Body;

				// Display message information.
				
			}
			
			catch (MessageQueueException)
			{
				
			}

			// Handle invalid serialization format. 
			catch (InvalidOperationException e)
			{
				
			}
			
			// Catch other exceptions as necessary. 

			return;
		}
	}
}

Mqmessages =new Message(“.\ProductOrders");
MessageEnumarator enummessages =new MessageEnumerator();
if (enumesages.MoveNext)
{
 product myProduct= (Product)myMessage.Body;


enumMessages.RemoveCurrent();
}