Skip to main content

How to Create, Add, Receive MSMQ

//How to Create a MessageQueue ?_______________________

static string myQueue = ".\\private$\\EmailQueue";  
 if (!MessageQueue.Exists(myQueue))
            {
                MessageQueue.Create(myQueue, false);
            }
            Console.WriteLine("Server is up and running on port 32578");

//How to Add MessageQueue :__________________________

 MessageQueue messageQueue = new MessageQueue(myQueue);
                    messageQueue.Send(emailDetail, "Email");


//How to Receive a MessageQueue :_____________________________________
 private static EmailDetails ReceiveMessage(string queueName)

        {
            log.Info(DateTime.Now + " Queue checking");
            MessageQueue messageQueue = new MessageQueue(queueName);
            EmailDetails emailDetail = null;
            try

            {
                messageQueue.Formatter = new XmlMessageFormatter(new Type[] { typeof(EmailDetails) });
                emailDetail = (EmailDetails)messageQueue.Receive().Body;
               
                //emailDetail is class obect where i have recieved object from queueu
                }
            }

            catch(Exception ex)
            {
                
            }

            finally

            {
                messageQueue.Close();
            }
            return emailDetail;
        }

Comments