Csharp/C Sharp by API/System.Messaging/MessageQueueTransaction — различия между версиями
Admin (обсуждение | вклад) м (1 версия) |
|
(нет различий)
|
Версия 15:31, 26 мая 2010
new MessageQueueTransaction()
using System;
using System.Messaging;
class MainClass
{
[STAThread]
static void Main(string[] args)
{
MessageQueue txq1 = new MessageQueue( @".\Private$\txq1" );
MessageQueue txq2 = new MessageQueue( @".\Private$\txq2" );
using ( MessageQueueTransaction mqtx = new MessageQueueTransaction() )
{
mqtx.Begin();
Message msgIn = txq1.Receive( mqtx );
msgIn.Formatter = new XmlMessageFormatter( new String[] { "System.String, mscorlib", } );
Message msgOut = new Message();
msgOut.Body = (string)msgIn.Body;
txq2.Send( msgOut, mqtx );
System.Console.WriteLine( "Aborting message: {0}", (string)msgIn.Body );
//mqtx.Abort();
mqtx.rumit();
}
}
}