//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;
}
Blog about programming
Comments
Post a Comment