using System; using System.Text.RegularExpressions; using System.Messaging;namespace ConsoleApplication1 { /// <summary> /// Summary description for Class1. /// </summary> class Class1 { /// <summary> /// The main entry point for the application. /// </summary> [STAThread] static void Main(string[] args) { // // TODO: Add code to start application here // MessageQueue myqueue = new MessageQueue(".\\private$\\xml_monitor");//消息队列的路径 myqueue.Send("message"); } } }
using System.Text.RegularExpressions;
using System.Messaging;namespace ConsoleApplication1
{
/// <summary>
/// Summary description for Class1.
/// </summary>
class Class1
{
/// <summary>
/// The main entry point for the application.
/// </summary>
[STAThread]
static void Main(string[] args)
{
//
// TODO: Add code to start application here
//
MessageQueue myqueue = new MessageQueue(".\\private$\\xml_monitor");//消息队列的路径
myqueue.Send("message");
}
}
}
Message [] GetAllMessage()方法 获取全部消息,在做循环时,每循环一次就要把当次的消息 Receive() 一次
mq.Formatter = new XmlMessageFormatter(new Type[] { typeof(Order) });
try
{
System.Messaging.Message [] mss = mq.GetAllMessages();
foreach (System.Messaging.Message ms in mss)
{
mq.Receive();
Order o = (Order)ms.Body;
MessageBox.Show("Message:ID=" + o.ID.ToString() + ", Count=" + o.Count.ToString());
}
}
catch
{
}