Mega Code Archive

 

Categories / C# / Web Services

 

MessageQueue

using System; using System.Messaging; [Serializable] class MyMessage {     private string data;     public MyMessage(string data) {         this.data = data;     }     public override string ToString() {         return data;     } } class Program {     static void Main(string[] args) {         try {             if (!MessageQueue.Exists(@".\Private$\MyPrivateQueue")) {                 MessageQueue.Create(@".\Private$\MyPrivateQueue");             }             MessageQueue queue = new MessageQueue(@".\Private$\MyPrivateQueue");             queue.Formatter = new BinaryMessageFormatter();             queue.Send("Sample Message", "Label");             MyMessage m = new MyMessage("xxx");             queue.Send(m, "Binary Test");         } catch (MessageQueueException ex) {             Console.WriteLine(ex.Message);         }     } }