MessageQueue.ReceiveCompleted イベント
アセンブリ: System.Messaging (system.messaging.dll 内)

Dim instance As MessageQueue Dim handler As ReceiveCompletedEventHandler AddHandler instance.ReceiveCompleted, handler
public: event ReceiveCompletedEventHandler^ ReceiveCompleted { void add (ReceiveCompletedEventHandler^ value); void remove (ReceiveCompletedEventHandler^ value); }

非同期処理では、BeginReceive を使用して、キューのメッセージが利用可能になったときに ReceiveCompleted イベントを発生させます。
ReceiveCompleted イベントが発生したときに、EndReceive を使用して BeginReceive 呼び出しで実行した操作を完了し、メッセージをピークします。
ReceiveCompletedEventHandler デリゲートを作成する場合は、イベントを処理するメソッドを識別してください。イベントをイベント ハンドラに関連付けるには、デリゲートのインスタンスをイベントに追加します。デリゲートを削除しない限り、そのイベントが発生すると常にイベント ハンドラが呼び出されます。イベント ハンドラ デリゲートの詳細については、「イベントとデリゲート」を参照してください。

MyReceiveCompleted イベント ハンドラを作成し、ReceiveCompleted イベント ハンドラ デリゲートに結び付け、BeginReceive を呼び出して非同期の受信操作を実行するコード例を次に示します。受信操作の対象になるキューは ".\myQueue" パスにあります。ReceiveCompleted イベントが発生すると、この例はメッセージを受信し、本文を画面に書き込みます。次に、BeginReceive をもう一度呼び出して、新しい非同期の受信操作を実行します。
Imports System Imports System.Messaging Public Class MyNewQueue ' ' Provides an entry point into the application. ' ' This example performs asynchronous receive operation ' processing. ' Public Shared Sub Main() ' Create an instance of MessageQueue. Set its formatter. Dim myQueue As New MessageQueue(".\myQueue") myQueue.Formatter = New XmlMessageFormatter(New Type() _ {GetType([String])}) ' Add an event handler for the ReceiveCompleted event. AddHandler myQueue.ReceiveCompleted, AddressOf _ MyReceiveCompleted ' Begin the asynchronous receive operation. myQueue.BeginReceive() ' Do other work on the current thread. Return End Sub 'Main ' ' Provides an event handler for the ReceiveCompleted ' event. ' Private Shared Sub MyReceiveCompleted(ByVal [source] As _ [Object], ByVal asyncResult As ReceiveCompletedEventArgs) ' Connect to the queue. Dim mq As MessageQueue = CType([source], MessageQueue) ' End the asynchronous Receive operation. Dim m As Message = mq.EndReceive(asyncResult.AsyncResult) ' Display message information on the screen. Console.WriteLine(("Message: " + CStr(m.Body))) ' Restart the asynchronous Receive operation. mq.BeginReceive() Return End Sub 'MyReceiveCompleted End Class 'MyNewQueue
using System; using System.Messaging; namespace MyProject { /// <summary> /// Provides a container class for the example. /// </summary> public class MyNewQueue { //************************************************** // Provides an entry point into the application. // // This example performs asynchronous receive operation // processing. //************************************************** public static void Main() { // Create an instance of MessageQueue. Set its formatter. MessageQueue myQueue = new MessageQueue(".\\myQueue"); myQueue.Formatter = new XmlMessageFormatter(new Type[] {typeof(String)}); // Add an event handler for the ReceiveCompleted event. myQueue.ReceiveCompleted += new ReceiveCompletedEventHandler(MyReceiveCompleted); // Begin the asynchronous receive operation. myQueue.BeginReceive(); // Do other work on the current thread. return; } //************************************************** // Provides an event handler for the ReceiveCompleted // event. //************************************************** private static void MyReceiveCompleted(Object source, ReceiveCompletedEventArgs asyncResult) { // Connect to the queue. MessageQueue mq = (MessageQueue)source; // End the asynchronous Receive operation. Message m = mq.EndReceive(asyncResult.AsyncResult); // Display message information on the screen. Console.WriteLine("Message: " + (string)m.Body); // Restart the asynchronous Receive operation. mq.BeginReceive(); return; } } }
#using <system.dll> #using <system.messaging.dll> using namespace System; using namespace System::Messaging; ref class MyNewQueue { public: //************************************************* // Provides an event handler for the ReceiveCompleted // event. //************************************************* static void MyReceiveCompleted( Object^ source, ReceiveCompletedEventArgs^ asyncResult ) { // Connect to the queue. MessageQueue^ mq = dynamic_cast<MessageQueue^>(source); // End the asynchronous Receive operation. Message^ m = mq->EndReceive( asyncResult->AsyncResult ); // Display message information on the screen. Console::WriteLine( "Message: {0}", m->Body ); // Restart the asynchronous Receive operation. mq->BeginReceive(); return; } }; //************************************************* // Provides an entry point into the application. // // This example performs asynchronous receive operation // processing. //************************************************* int main() { // Create an instance of MessageQueue. Set its formatter. MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" ); array<Type^>^p = gcnew array<Type^>(1); p[ 0 ] = String::typeid; myQueue->Formatter = gcnew XmlMessageFormatter( p ); // Add an event handler for the ReceiveCompleted event. myQueue->ReceiveCompleted += gcnew ReceiveCompletedEventHandler( MyNewQueue::MyReceiveCompleted ); // Begin the asynchronous receive operation. myQueue->BeginReceive(); // Do other work on the current thread. return 0; }
package MyProject; import System.*; import System.Messaging.*; /// <summary> /// Provides a container class for the example. /// </summary> public class MyNewQueue { //************************************************** // Provides an entry point into the application. // // This example performs asynchronous receive operation // processing. //************************************************** public static void main(String[] args) { // Create an instance of MessageQueue. Set its formatter. MessageQueue myQueue = new MessageQueue(".\\myQueue"); myQueue.set_Formatter(new XmlMessageFormatter(new Type[] { String.class.ToType() })); // Add an event handler for the ReceiveCompleted event. myQueue.add_ReceiveCompleted(new ReceiveCompletedEventHandler (MyReceiveCompleted)); // Begin the asynchronous receive operation. myQueue.BeginReceive(); // Do other work on the current thread. return; } //main //************************************************** // Provides an event handler for the ReceiveCompleted // event. //************************************************** private static void MyReceiveCompleted(Object source, ReceiveCompletedEventArgs asyncResult) { // Connect to the queue. MessageQueue mq = (MessageQueue)source; // End the asynchronous Receive operation. Message m = mq.EndReceive(asyncResult.get_AsyncResult()); // Display message information on the screen. Console.WriteLine("Message: " + (String)(m.get_Body())); // Restart the asynchronous Receive operation. mq.BeginReceive(); return; } //MyReceiveCompleted } //MyNewQueue


Windows 98, Windows 2000 SP4, Windows CE, Windows Millennium Edition, Windows Mobile for Pocket PC, Windows Mobile for Smartphone, Windows Server 2003, Windows XP Media Center Edition, Windows XP Professional x64 Edition, Windows XP SP2, Windows XP Starter Edition
開発プラットフォームの中には、.NET Framework によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。


MessageQueue クラス
MessageQueue メンバ
System.Messaging 名前空間
BeginReceive
MessageQueue.PeekCompleted イベント
TimeSpan
AsyncCallback
IAsyncResult
Weblioに収録されているすべての辞書からMessageQueue.ReceiveCompleted イベントを検索する場合は、下記のリンクをクリックしてください。

- MessageQueue.ReceiveCompleted イベントのページへのリンク