MessageQueue.EndPeek メソッド
アセンブリ: System.Messaging (system.messaging.dll 内)

Dim instance As MessageQueue Dim asyncResult As IAsyncResult Dim returnValue As Message returnValue = instance.EndPeek(asyncResult)
戻り値
完了する非同期操作に関連付けられた Message。


PeekCompleted イベントが発生したときに、EndPeek は BeginPeek 呼び出しで開始された操作を完了します。操作を完了するために、EndPeek はメッセージをピークします。
BeginPeek はタイムアウトを指定できます。タイムアウトを指定すると、キューにメッセージが到達する前にタイムアウトが発生した場合に、PeekCompleted イベントが発生します。この場合、asyncResult パラメータの IsCompleted プロパティは true に設定されますが、メッセージは操作に関連付けられません。メッセージがキューに到達する前にタイムアウトが発生すると、後続の EndPeek 呼び出しは例外をスローします。
PeekCompleted イベントを発生させたメッセージを読み取るには、EndPeek を使用します。
メッセージを非同期にピークし続けるには、EndPeek を呼び出した後でもう一度 BeginPeek を呼び出します。
このメソッドが各種のワークグループ モードで使用できるかどうかを次の表に示します。

MyPeekCompleted イベント ハンドラを作成し、PeekCompleted イベント ハンドラ デリゲートに結び付け、BeginPeek を呼び出して非同期のピーク操作を実行するコード例を次に示します。ピーク操作の対象になるキューは ".\myQueue" パスにあります。PeekCompleted イベントが発生すると、この例はメッセージをピークし、本文を画面に書き込みます。次に、BeginPeek をもう一度呼び出して、新しい非同期のピーク操作を実行します。
Imports System Imports System.Messaging ' Provides a container class for the example. Public Class MyNewQueue ' Provides an entry point into the application. ' ' This example performs asynchronous peek 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 PeekCompleted event. AddHandler myQueue.PeekCompleted, AddressOf _ MyPeekCompleted ' Begin the asynchronous peek operation. myQueue.BeginPeek() ' Do other work on the current thread. Return End Sub 'Main '************************************************** ' Provides an event handler for the PeekCompleted ' event. '************************************************** Private Shared Sub MyPeekCompleted(ByVal [source] As _ [Object], ByVal asyncResult As PeekCompletedEventArgs) ' Connect to the queue. Dim mq As MessageQueue = CType([source], MessageQueue) ' End the asynchronous peek operation. Dim m As Message = mq.EndPeek(asyncResult.AsyncResult) ' Display message information on the screen. Console.WriteLine(("Message: " + CStr(m.Body))) ' Restart the asynchronous peek operation. mq.BeginPeek() Return End Sub 'MyPeekCompleted 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 peek 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 PeekCompleted event. myQueue.PeekCompleted += new PeekCompletedEventHandler(MyPeekCompleted); // Begin the asynchronous peek operation. myQueue.BeginPeek(); // Do other work on the current thread. return; } //************************************************** // Provides an event handler for the PeekCompleted // event. //************************************************** private static void MyPeekCompleted(Object source, PeekCompletedEventArgs asyncResult) { // Connect to the queue. MessageQueue mq = (MessageQueue)source; // End the asynchronous peek operation. Message m = mq.EndPeek(asyncResult.AsyncResult); // Display message information on the screen. Console.WriteLine("Message: " + (string)m.Body); // Restart the asynchronous peek operation. mq.BeginPeek(); return; } } }
#using <system.dll> #using <system.messaging.dll> using namespace System; using namespace System::Messaging; // This example performs asynchronous peek operation // processing. //************************************************* ref class MyNewQueue { public: // Provides an event handler for the PeekCompleted // event. static void MyPeekCompleted( Object^ source, PeekCompletedEventArgs^ asyncResult ) { // Connect to the queue. MessageQueue^ mq = dynamic_cast<MessageQueue^>(source); // End the asynchronous peek operation. Message^ m = mq->EndPeek( asyncResult->AsyncResult ); // Display message information on the screen. Console::WriteLine( "Message: {0}", static_cast<String^>(m->Body) ); // Restart the asynchronous peek operation. mq->BeginPeek(); return; } }; // Provides an entry point into the application. // 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 PeekCompleted event. myQueue->PeekCompleted += gcnew PeekCompletedEventHandler( MyNewQueue::MyPeekCompleted ); // Begin the asynchronous peek operation. myQueue->BeginPeek(); // 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 peek 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 PeekCompleted event. myQueue.add_PeekCompleted(new PeekCompletedEventHandler(MyPeekCompleted)); // Begin the asynchronous peek operation. myQueue.BeginPeek(); // Do other work on the current thread. return; } //main //************************************************** // Provides an event handler for the PeekCompleted // event. //************************************************** private static void MyPeekCompleted(Object source, PeekCompletedEventArgs asyncResult) { // Connect to the queue. MessageQueue mq = (MessageQueue)source; // End the asynchronous peek operation. Message m = mq.EndPeek(asyncResult.get_AsyncResult()); // Display message information on the screen. Console.WriteLine("Message: " + (String)(m.get_Body())); // Restart the asynchronous peek operation. mq.BeginPeek(); return; } //MyPeekCompleted } //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 によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。


Weblioに収録されているすべての辞書からMessageQueue.EndPeek メソッドを検索する場合は、下記のリンクをクリックしてください。

- MessageQueue.EndPeek メソッドのページへのリンク