MessageQueueとは何？わかりやすく解説 Weblio辞書

パブリックイベントパブリックイベント

	名前	説明
	Disposed	コンポーネントの Disposed イベントを待機するイベントハンドラを追加します。 ( Component から継承されます。)
	PeekCompleted	キューから削除せずにメッセージを読み取ると発生します。この発生は、非同期操作 BeginPeek の結果です。
	ReceiveCompleted	メッセージがキューから削除されると発生します。このイベントは、非同期操作 BeginReceive によって発生します。

参照

関連項目

MessageQueue クラス
System.Messaging 名前空間
Message クラス
DefaultPropertiesToSend クラス
MessageQueueException
MessageQueue
Peek
Receive
BeginPeek
BeginReceive
MessageQueue.Path プロパティ
MessageQueue.Label プロパティ
MessageQueue.FormatName プロパティ
MessageQueue.QueueName プロパティ
MessageQueue.MachineName プロパティ

メッセージキューサーバーのキューにアクセスできるようにします。

名前空間: System.Messaging
アセンブリ: System.Messaging (system.messaging.dll 内)
構文

Visual Basic (宣言)

Public Class MessageQueue
    Inherits Component
    Implements IEnumerable

Visual Basic (使用法)

Dim instance As MessageQueue

C#

public class MessageQueue : Component, IEnumerable

C++

public ref class MessageQueue : public
 Component, IEnumerable

J#

public class MessageQueue extends Component
 implements IEnumerable

JScript

public class MessageQueue extends
 Component implements IEnumerable

解説

メッセージキューの技術を使用すると、一時的にオフラインになる可能性のある異種ネットワークや異種システム間で、異なる時間に実行される複数のアプリケーションが相互に通信できます。アプリケーションは、キューからのメッセージを送信、受信、またはピーク (削除せずに読み取ること) します。メッセージキューは Windows 2000 および Windows NT のオプションのコンポーネントです。個別にインストールする必要があります。

MessageQueue クラスは、メッセージキューのラッパークラスです。メッセージキューには複数のバージョンがあり、使用しているオペレーティングシステムによって MessageQueue クラスの動作が少し異なります。メッセージキューの各バージョンにおける固有の機能の詳細については、MSDN のプラットフォーム SDK ドキュメントのトピック「What's New in Message Queuing」を参照してください。

MessageQueue クラスによりメッセージキューのキューへの参照ができます。MessageQueue コンストラクタでパスを指定して既存のリソースに接続するか、サーバーに新しいキューを作成できます。Send(Object)、Peek、または Receive を呼び出す前に、MessageQueue クラスの新しいインスタンスを既存のキューに関連付ける必要があります。この時点で、Category や Label などのキュープロパティの操作ができるようになります。

MessageQueue は、同期と非同期の 2 種類のメッセージ取得をサポートします。同期メソッドである Peek と Receive を使用して、プロセススレッドは新しいメッセージがキューに到達するまで待機する時間間隔を指定します。非同期メソッドである BeginPeek と BeginReceive を使用すると、キューにメッセージが到達するまで、メインアプリケーションのタスクは別のスレッドで継続します。これらのメソッドは、コールバックオブジェクトと状態オブジェクトを使用してスレッド間で情報を通信することによって動作します。

MessageQueue クラスの新しいインスタンスを作成するときに、新しいメッセージキューのキューは作成されません。その代わりに、Create(String)、Delete、Purge の各メソッドを使用してサーバーのキューを管理できます。

Purge とは異なり、Create(String) と Delete は static メンバであるため、MessageQueue クラスの新しいインスタンスを作成せずに呼び出すことができます。

MessageQueue オブジェクトの Path プロパティには、表示名、FormatName、Label など、3 種類ある名前のうちの 1 つを設定できます。表示名とは、キューの MachineName プロパティと QueueName プロパティで定義される名前であり、パブリックキューの場合は MachineName \ QueueName、プライベートキューの場合は MachineName \ Private$ \ QueueName です。FormatName プロパティを使用すると、メッセージキューにオフラインでアクセスできます。キューの Label プロパティを使用してキューの Path を設定することもできます。

MessageQueue のインスタンスの初期プロパティ値の一覧については、MessageQueue コンストラクタのトピックを参照してください。

使用例

さまざまな種類のパス名構文を使用して、新しい MessageQueue オブジェクトを作成するコード例を次に示します。いずれの場合も、コンストラクタでパスが定義されているキューにメッセージを送信します。

Visual Basic

Imports System
Imports System.Messaging

Public Class MyNewQueue


        
        ' Provides an entry point into the application.
        '         
        ' This example demonstrates several ways to set
        ' a queue's path.
        

        Public Shared Sub
 Main()

            ' Create a new instance of the class.
            Dim myNewQueue As New
 MyNewQueue()

            myNewQueue.SendPublic()
            myNewQueue.SendPrivate()
            myNewQueue.SendByLabel()
            myNewQueue.SendByFormatName()
            myNewQueue.MonitorComputerJournal()
            myNewQueue.MonitorQueueJournal()
            myNewQueue.MonitorDeadLetter()
            myNewQueue.MonitorTransactionalDeadLetter()

            Return

        End Sub 'Main


        ' References public queues.
        Public Sub SendPublic()

            Dim myQueue As New
 MessageQueue(".\myQueue")
            myQueue.Send("Public queue by path name.")

            Return

        End Sub 'SendPublic


        ' References private queues.
        Public Sub SendPrivate()

            Dim myQueue As New
 MessageQueue(".\Private$\myQueue")
            myQueue.Send("Private queue by path name.")

            Return

        End Sub 'SendPrivate


        ' References queues by label.
        Public Sub SendByLabel()

            Dim myQueue As New
 MessageQueue("Label:TheLabel")
            myQueue.Send("Queue by label.")

            Return

        End Sub 'SendByLabel


        ' References queues by format name.
        Public Sub SendByFormatName()

            Dim myQueue As New
 _
                MessageQueue("FormatName:Public="
 + _
                    "5A5F7535-AE9A-41d4-935C-845C2AFF7112")
            myQueue.Send("Queue by format name.")

            Return

        End Sub 'SendByFormatName


        ' References computer journal queues.
        Public Sub MonitorComputerJournal()

            Dim computerJournal As New
 MessageQueue(".\Journal$")

            While True

                Dim journalMessage As Message
 = _
                    computerJournal.Receive()

                ' Process the journal message.

            End While

            Return
        End Sub 'MonitorComputerJournal


        ' References queue journal queues.
        Public Sub MonitorQueueJournal()

            Dim queueJournal As New
 _
                            MessageQueue(".\myQueue\Journal$")

            While True

                Dim journalMessage As Message
 = _
                    queueJournal.Receive()

                ' Process the journal message.

            End While

            Return
        End Sub 'MonitorQueueJournal


        ' References dead-letter queues.
        Public Sub MonitorDeadLetter()
            Dim deadLetter As New
 MessageQueue(".\DeadLetter$")

            While True

                Dim deadMessage As Message
 = deadLetter.Receive()

                ' Process the dead-letter message.

            End While

            Return

        End Sub 'MonitorDeadLetter


        ' References transactional dead-letter queues.
        Public Sub MonitorTransactionalDeadLetter()

            Dim TxDeadLetter As New
 MessageQueue(".\XactDeadLetter$")

            While True

                Dim txDeadLetterMessage As
 Message = _
                    TxDeadLetter.Receive()

                ' Process the transactional dead-letter message.

            End While

            Return

        End Sub 'MonitorTransactionalDeadLetter

End Class 'MyNewQueue

C#

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 demonstrates several ways to set
        // a queue's path.
        //**************************************************

        public static void
 Main()
        {
            // Create a new instance of the class.
            MyNewQueue myNewQueue = new MyNewQueue();

            myNewQueue.SendPublic();
            myNewQueue.SendPrivate();
            myNewQueue.SendByLabel();
            myNewQueue.SendByFormatName();
            myNewQueue.MonitorComputerJournal();
            myNewQueue.MonitorQueueJournal();
            myNewQueue.MonitorDeadLetter();
            myNewQueue.MonitorTransactionalDeadLetter();

            return;
        }
        
        // References public queues.
        public void SendPublic()
        {
            MessageQueue myQueue = new MessageQueue(".\\myQueue");
            myQueue.Send("Public queue by path name.");

            return;
        }

        // References private queues.
        public void SendPrivate()
        {
            MessageQueue myQueue = new 
                MessageQueue(".\\Private$\\myQueue");
            myQueue.Send("Private queue by path name.");

            return;
        }

        // References queues by label.
        public void SendByLabel()
        {
            MessageQueue myQueue = new MessageQueue("Label:TheLabel");
            myQueue.Send("Queue by label.");

            return;
        }

        // References queues by format name.
        public void SendByFormatName()
        {
            MessageQueue myQueue = new 
                MessageQueue("FormatName:Public=5A5F7535-AE9A-41d4" + 
                "-935C-845C2AFF7112");
            myQueue.Send("Queue by format name.");

            return;
        }

        // References computer journal queues.
        public void MonitorComputerJournal()
        {
            MessageQueue computerJournal = new 
                MessageQueue(".\\Journal$");
            while(true)
            {
                Message journalMessage = computerJournal.Receive();
                // Process the journal message.
            }
        }

        // References queue journal queues.
        public void MonitorQueueJournal()
        {
            MessageQueue queueJournal = new 
                MessageQueue(".\\myQueue\\Journal$");
            while(true)
            {
                Message journalMessage = queueJournal.Receive();
                // Process the journal message.
            }
        }
        
        // References dead-letter queues.
        public void MonitorDeadLetter()
        {
            MessageQueue deadLetter = new 
                MessageQueue(".\\DeadLetter$");
            while(true)
            {
                Message deadMessage = deadLetter.Receive();
                // Process the dead-letter message.
            }
        }

        // References transactional dead-letter queues.
        public void MonitorTransactionalDeadLetter()
        {
            MessageQueue TxDeadLetter = new 
                MessageQueue(".\\XactDeadLetter$");
            while(true)
            {
                Message txDeadLetter = TxDeadLetter.Receive();
                // Process the transactional dead-letter message.
            }
        }

    }
}

C++

#using <system.dll>
#using <system.messaging.dll>

using namespace System;
using namespace System::Messaging;
ref class MyNewQueue
{
public:

   // References public queues.
   void SendPublic()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );
      myQueue->Send( "Public queue by path name." );
      return;
   }


   // References private queues.
   void SendPrivate()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\Private$\\myQueue"
 );
      myQueue->Send( "Private queue by path name." );
      return;
   }


   // References queues by label.
   void SendByLabel()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( "Label:TheLabel" );
      myQueue->Send( "Queue by label." );
      return;
   }


   // References queues by format name.
   void SendByFormatName()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( "FormatName:Public=5A5F7535-AE9A-41d4
 -935C-845C2AFF7112" );
      myQueue->Send( "Queue by format name." );
      return;
   }


   // References computer journal queues.
   void MonitorComputerJournal()
   {
      MessageQueue^ computerJournal = gcnew MessageQueue( ".\\Journal$"
 );
      while ( true )
      {
         Message^ journalMessage = computerJournal->Receive();
         
         // Process the journal message.
      }
   }


   // References queue journal queues.
   void MonitorQueueJournal()
   {
      MessageQueue^ queueJournal = gcnew MessageQueue( ".\\myQueue\\Journal$"
 );
      while ( true )
      {
         Message^ journalMessage = queueJournal->Receive();
         
         // Process the journal message.
      }
   }


   // References dead-letter queues.
   void MonitorDeadLetter()
   {
      MessageQueue^ deadLetter = gcnew MessageQueue( ".\\DeadLetter$" );
      while ( true )
      {
         Message^ deadMessage = deadLetter->Receive();
         
         // Process the dead-letter message.
      }
   }


   // References transactional dead-letter queues.
   void MonitorTransactionalDeadLetter()
   {
      MessageQueue^ TxDeadLetter = gcnew MessageQueue( ".\\XactDeadLetter$"
 );
      while ( true )
      {
         Message^ txDeadLetter = TxDeadLetter->Receive();
         
         // Process the transactional dead-letter message.
      }
   }

};


//*************************************************
// Provides an entry point into the application.
//         
// This example demonstrates several ways to set
// a queue's path.
//*************************************************
int main()
{
   
   // Create a new instance of the class.
   MyNewQueue^ myNewQueue = gcnew MyNewQueue;
   myNewQueue->SendPublic();
   myNewQueue->SendPrivate();
   myNewQueue->SendByLabel();
   myNewQueue->SendByFormatName();
   myNewQueue->MonitorComputerJournal();
   myNewQueue->MonitorQueueJournal();
   myNewQueue->MonitorDeadLetter();
   myNewQueue->MonitorTransactionalDeadLetter();
   return 0;
}

J#

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 demonstrates several ways to set
    // a queue's path.
    //**************************************************
    public static void main(String[]
 args)
    {
        // Create a new instance of the class.
        MyNewQueue myNewQueue = new MyNewQueue();

        myNewQueue.SendPublic();
        myNewQueue.SendPrivate();
        myNewQueue.SendByLabel();
        myNewQueue.SendByFormatName();
        myNewQueue.MonitorComputerJournal();
        myNewQueue.MonitorQueueJournal();
        myNewQueue.MonitorDeadLetter();
        myNewQueue.MonitorTransactionalDeadLetter();

        return;
    } //main

    // References public queues.
    public void SendPublic()
    {
        MessageQueue myQueue = new MessageQueue(".\\myQueue");
        myQueue.Send("Public queue by path name.");
        return;
    } //SendPublic

    // References private queues.
    public void SendPrivate()
    {
        MessageQueue myQueue = new MessageQueue(".\\Private$\\myQueue");
        myQueue.Send("Private queue by path name.");
        return;
    } //SendPrivate

    // References queues by label.
    public void SendByLabel()
    {
        MessageQueue myQueue = new MessageQueue("Label:TheLabel");
        myQueue.Send("Queue by label.");
        return;
    } //SendByLabel

    // References queues by format name.
    public void SendByFormatName()
    {
        MessageQueue myQueue =
            new MessageQueue("FormatName:Public=5A5F7535-AE9A-41d4"
            + "-935C-845C2AFF7112");
        myQueue.Send("Queue by format name.");
        return;
    } //SendByFormatName

    // References computer journal queues.
    public void MonitorComputerJournal()
    {
        MessageQueue computerJournal = new MessageQueue(".\\Journal$");
        while (true) {
            Message journalMessage = computerJournal.Receive();
            // Process the journal message.
        }
    } //MonitorComputerJournal

    // References queue journal queues.
    public void MonitorQueueJournal()
    {
        MessageQueue queueJournal = new MessageQueue(".\\myQueue\\Journal$");
        while (true) {
            Message journalMessage = queueJournal.Receive();
            // Process the journal message.
        }
    } //MonitorQueueJournal

    // References dead-letter queues.
    public void MonitorDeadLetter()
    {
        MessageQueue deadLetter = new MessageQueue(".\\DeadLetter$");
        while (true) {
            Message deadMessage = deadLetter.Receive();
            // Process the dead-letter message.
        }
    } //MonitorDeadLetter

    // References transactional dead-letter queues.
    public void MonitorTransactionalDeadLetter()
    {
        MessageQueue objTxDeadLetter = new MessageQueue(".\\XactDeadLetter$");
        while (true) {
            Message txDeadLetter = objTxDeadLetter.Receive();
            // Process the transactional dead-letter message.
        }
    } //MonitorTransactionalDeadLetter
} //MyNewQueue

アプリケーション固有の Order というクラスを使用して、メッセージをキューに送信し、キューからメッセージを受信するコード例を次に示します。

Visual Basic

Imports System
Imports System.Messaging

    ' This class represents an object the following example 
    ' sends to a queue and receives from a queue.
    Public Class Order
        Public orderId As Integer
        Public orderTime As DateTime
    End Class 'Order


   
    Public Class MyNewQueue


        '
        ' Provides an entry point into the application.
        '         
        ' This example sends and receives a message from
        ' a qeue.
        '

        Public Shared Sub
 Main()

            ' Create a new instance of the class.
            Dim myNewQueue As New
 MyNewQueue()

            ' Send a message to a queue.
            myNewQueue.SendMessage()

            ' Receive a message from a queue.
            myNewQueue.ReceiveMessage()

            Return

        End Sub 'Main


        '
        ' Sends an Order to a queue.
        '

        Public Sub SendMessage()

            ' Create a new order and set values.
            Dim sentOrder As New
 Order()
            sentOrder.orderId = 3
            sentOrder.orderTime = DateTime.Now

            ' Connect to a queue on the local computer.
            Dim myQueue As New
 MessageQueue(".\myQueue")

            ' Send the Order to the queue.
            myQueue.Send(sentOrder)

            Return

        End Sub 'SendMessage


        '
        ' Receives a message containing an Order.
        '

        Public Sub ReceiveMessage()

            ' Connect to the a queue on the local computer.
            Dim myQueue As New
 MessageQueue(".\myQueue")

            ' Set the formatter to indicate the body contains an Order.
            myQueue.Formatter = New XmlMessageFormatter(New
 Type() _
                {GetType(Order)})

            Try

                ' Receive and format the message. 
                Dim myMessage As Message =
 myQueue.Receive()
                Dim myOrder As Order = CType(myMessage.Body,
 Order)

                ' Display message information.
                Console.WriteLine(("Order ID: " +
 _
                    myOrder.orderId.ToString()))
                Console.WriteLine(("Sent: " + _
                    myOrder.orderTime.ToString()))

            Catch m As MessageQueueException
                ' Handle Message Queuing exceptions.

            Catch e As InvalidOperationException
                ' Handle invalid serialization format.
                Console.WriteLine(e.Message)


                ' Catch other exceptions as necessary.

            End Try

            Return

        End Sub 'ReceiveMessage

End Class 'MyNewQueue

C#

using System;
using System.Messaging;

namespace MyProject
{

    // This class represents an object the following example 
    // sends to a queue and receives from a queue.
    public class Order
    {
        public int orderId;
        public DateTime orderTime;
    };    

    /// <summary>
    /// Provides a container class for the example.
    /// </summary>
    public class MyNewQueue
    {

        //**************************************************
        // Provides an entry point into the application.
        //         
        // This example sends and receives a message from
        // a queue.
        //**************************************************

        public static void
 Main()
        {
            // Create a new instance of the class.
            MyNewQueue myNewQueue = new MyNewQueue();

            // Send a message to a queue.
            myNewQueue.SendMessage();

            // Receive a message from a queue.
            myNewQueue.ReceiveMessage();

            return;
        }


        //**************************************************
        // Sends an Order to a queue.
        //**************************************************
        
        public void SendMessage()
        {
            
            // Create a new order and set values.
            Order sentOrder = new Order();
            sentOrder.orderId = 3;
            sentOrder.orderTime = DateTime.Now;

            // Connect to a queue on the local computer.
            MessageQueue myQueue = new MessageQueue(".\\myQueue");

            // Send the Order to the queue.
            myQueue.Send(sentOrder);

            return;
        }


        //**************************************************
        // Receives a message containing an Order.
        //**************************************************
        
        public  void ReceiveMessage()
        {
            // Connect to the a queue on the local computer.
            MessageQueue myQueue = new MessageQueue(".\\myQueue");

            // Set the formatter to indicate body contains an Order.
            myQueue.Formatter = new XmlMessageFormatter(new
 Type[]
                {typeof(MyProject.Order)});
            
            try
            {
                // Receive and format the message. 
                Message myMessage =    myQueue.Receive(); 
                Order myOrder = (Order)myMessage.Body;

                // Display message information.
                Console.WriteLine("Order ID: " + 
                    myOrder.orderId.ToString());
                Console.WriteLine("Sent: " + 
                    myOrder.orderTime.ToString());
            }
            
            catch (MessageQueueException)
            {
                // Handle Message Queuing exceptions.
            }

            // Handle invalid serialization format.
            catch (InvalidOperationException e)
            {
                Console.WriteLine(e.Message);
            }
            
            // Catch other exceptions as necessary.

            return;
        }
    }
}

C++

#using <system.dll>
#using <system.messaging.dll>

using namespace System;
using namespace System::Messaging;

// This class represents an object the following example 
// sends to a queue and receives from a queue.
ref class Order
{
public:
   int orderId;
   DateTime orderTime;
};


/// <summary>
/// Provides a container class for the example.
/// </summary>
ref class MyNewQueue
{
public:

   //*************************************************
   // Sends an Order to a queue.
   //*************************************************
   void SendMessage()
   {
      // Create a new order and set values.
      Order^ sentOrder = gcnew Order;
      sentOrder->orderId = 3;
      sentOrder->orderTime = DateTime::Now;

      // Connect to a queue on the local computer.
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );

      // Send the Order to the queue.
      myQueue->Send( sentOrder );
      return;
   }

   //*************************************************
   // Receives a message containing an Order.
   //*************************************************
   void ReceiveMessage()
   {
      // Connect to the a queue on the local computer.
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );

      // Set the formatter to indicate body contains an Order.
      array<Type^>^p = gcnew array<Type^>(1);
      p[ 0 ] = Order::typeid;
      myQueue->Formatter = gcnew XmlMessageFormatter( p );
      try
      {
         // Receive and format the message. 
         Message^ myMessage = myQueue->Receive();
         Order^ myOrder = static_cast<Order^>(myMessage->Body);

         // Display message information.
         Console::WriteLine( "Order ID: {0}", myOrder->orderId );
         Console::WriteLine( "Sent: {0}", myOrder->orderTime );
      }
      catch ( MessageQueueException^ ) 
      {
         // Handle Message Queuing exceptions.
      }
      // Handle invalid serialization format.
      catch ( InvalidOperationException^ e ) 
      {
         Console::WriteLine( e->Message );
      }

      // Catch other exceptions as necessary.
      return;
   }
};

//*************************************************
// Provides an entry point into the application.
//         
// This example sends and receives a message from
// a queue.
//*************************************************
int main()
{
   // Create a new instance of the class.
   MyNewQueue^ myNewQueue = gcnew MyNewQueue;

   // Send a message to a queue.
   myNewQueue->SendMessage();

   // Receive a message from a queue.
   myNewQueue->ReceiveMessage();
   return 0;
}

J#

package MyProject;

import System.*;
import System.Messaging.*;

// This class represents an object the following example 
// sends to a queue and receives from a queue.
public class Order
{
    public int orderId;
    public DateTime orderTime;
} //Order

/// <summary>
/// Provides a container class for the example.
/// </summary>
public class MyNewQueue
{
    //**************************************************
    // Provides an entry point into the application.
    //         
    // This example sends and receives a message from
    // a queue.
    //**************************************************
    public static void main(String[]
 args)
    {
        // Create a new instance of the class.
        MyNewQueue myNewQueue = new MyNewQueue();
        // Send a message to a queue.
        myNewQueue.SendMessage();
        // Receive a message from a queue.
        myNewQueue.ReceiveMessage();

        return;
    } //main

    //**************************************************
    // Sends an Order to a queue.
    //**************************************************
    public void SendMessage()
    {
        // Create a new order and set values.
        Order sentOrder = new Order();
        sentOrder.orderId = 3;
        sentOrder.orderTime = DateTime.get_Now();
        // Connect to a queue on the local computer.
        MessageQueue myQueue = new MessageQueue(".\\myQueue");
        // Send the Order to the queue.
        myQueue.Send(sentOrder);

        return;
    } //SendMessage

    //**************************************************
    // Receives a message containing an Order.
    //**************************************************
    public void ReceiveMessage()
    {
        // Connect to the a queue on the local computer.
        MessageQueue myQueue = new MessageQueue(".\\myQueue");
        // Set the formatter to indicate body contains an Order.
        myQueue.set_Formatter(new XmlMessageFormatter(new
 Type[] 
            { MyProject.Order.class.ToType() }));
        try {
            // Receive and format the message. 
            Message myMessage = myQueue.Receive();
            Order myOrder = (Order)(myMessage.get_Body());
            // Display message information.
            Console.WriteLine("Order ID: "+((Int32)myOrder.orderId).ToString());
            Console.WriteLine("Sent: " + myOrder.orderTime.ToString());
        }
        catch (MessageQueueException exp) {
            // Handle Message Queuing exceptions.
        }
        // Handle invalid serialization format.
        catch (InvalidOperationException e) {
            Console.WriteLine(e.get_Message());
        }
        // Catch other exceptions as necessary.
        return;
    } //ReceiveMessage
} //MyNewQueue

継承階層

System.Object
   System.MarshalByRefObject
     System.ComponentModel.Component
      System.Messaging.MessageQueue

スレッドセーフ

マルチスレッド操作で安全なのは、BeginPeek、BeginReceive、EndPeek、EndReceive、GetAllMessages、Peek、Receive の各メソッドだけです。

プラットフォーム

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 によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。

バージョン情報

.NET Framework
サポート対象 : 2.0、1.1、1.0
.NET Compact Framework
サポート対象 : 2.0

参照

関連項目
MessageQueue メンバ
System.Messaging 名前空間
Message クラス
DefaultPropertiesToSend クラス
MessageQueueException
MessageQueue
Peek
Receive
BeginPeek
BeginReceive
Path
Label
FormatName
QueueName
MachineName

MessageQueue クラスの新しいインスタンスを初期化します。既定のコンストラクタが新しいインスタンスを初期化した後、そのインスタンスを使用する前にインスタンスの Path プロパティを設定する必要があります。

名前空間: System.Messaging
アセンブリ: System.Messaging (system.messaging.dll 内)
構文

Visual Basic (宣言)

Public Sub New

Visual Basic (使用法)

Dim instance As New MessageQueue

C#

public MessageQueue ()

C++

public:
MessageQueue ()

J#

public MessageQueue ()

JScript

public function MessageQueue ()

解説

このオーバーロードを使用して、メッセージキューサーバーのキューにすぐには結び付けられない MessageQueue クラスの新しいインスタンスを作成します。このインスタンスを使用する前に、Path プロパティを設定して、既存のメッセージキューのキューに接続する必要があります。または、MessageQueue 参照に Create(String) メソッドの戻り値を設定して、新しいメッセージキューのキューを作成することもできます。

MessageQueue コンストラクタは MessageQueue クラスの新しいインスタンスをインスタンス化します。メッセージキューの新しいキューは作成しません。

MessageQueue のインスタンスの初期プロパティ値を次の表に示します。

プロパティ	初期値
DefaultPropertiesToSend	DefaultPropertiesToSend クラスの既定のコンストラクタで設定される値。
Formatter	XmlMessageFormatter
MessageReadPropertyFilter	MessagePropertyFilter クラスの既定のコンストラクタで設定される値。すべてのフィルタ値が true に設定されます。
DenySharedReceive	false

使用例

新しい MessageQueue を作成するコード例を次に示します。

C#

// Connect to a queue on the local computer. You must set the queue's
// Path property before you can use the queue.
MessageQueue queue = new MessageQueue();
queue.Path = ".\\exampleQueue";

J#

// Connect to a queue on the local computer. You must set the queue's
// Path property before you can use the queue.
MessageQueue queue = new MessageQueue();
queue.set_Path(".\\exampleQueue");

.NET Framework のセキュリティ

直前の呼び出し元に対する完全な信頼。このメンバは、部分的に信頼されているコードから使用することはできません。詳細については、「」を参照してください。

プラットフォーム

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 によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。

バージョン情報

.NET Framework
サポート対象 : 2.0、1.1、1.0
.NET Compact Framework
サポート対象 : 2.0

参照

関連項目
MessageQueue クラス
MessageQueue メンバ
System.Messaging 名前空間
Path
QueueName
FormatName
Label

指定したパスのメッセージキューのキューを参照する MessageQueue クラスの新しいインスタンスを初期化します。

名前空間: System.Messaging
アセンブリ: System.Messaging (system.messaging.dll 内)
構文

Visual Basic (宣言)

Public Sub New ( _
    path As String _
)

Visual Basic (使用法)

Dim path As String

Dim instance As New MessageQueue(path)

C#

public MessageQueue (
    string path
)

C++

public:
MessageQueue (
    String^ path
)

J#

public MessageQueue (
    String path
)

JScript

public function MessageQueue (
    path : String
)

パラメータ

path: この MessageQueue が参照するキューの場所。

例外

例外の種類	条件
ArgumentException	Path プロパティが無効です。設定されていない可能性があります。

解説

パス、書式名、ラベルが判明している、メッセージキューの特定のキューに MessageQueue の新しいインスタンスを結び付ける場合は、このオーバーロードを使用します。キューを参照する最初のアプリケーションに排他アクセス許可を与える場合は、DenySharedReceive プロパティに true を設定するか、読み取りアクセス制限パラメータを渡すコンストラクタを使用する必要があります。

MessageQueue コンストラクタは MessageQueue クラスの新しいインスタンスをインスタンス化します。メッセージキューの新しいキューは作成しません。メッセージキューに新しいキューを作成するには、Create(String) を使用します。

path パラメータの構文は、参照するキューの種類によって異なります。詳細については、次の表を参照してください。

キューの種類	構文
パブリックキュー	MachineName\QueueName
プライベートキュー	MachineName\Private$\QueueName
ジャーナルキュー	MachineName\QueueName\Journal$
コンピュータの履歴キュー	MachineName\Journal$
コンピュータ配信不能キュー	MachineName\Deadletter$
コンピュータトランザクション配信不能キュー	MachineName\XactDeadletter$

代わりに、FormatName または Label を使用してキューのパスを記述することもできます。詳細については、次の表を参照してください。

参照	構文	例
書式名	FormatName: [ format name ]	FormatName:Public= 5A5F7535-AE9A-41d4-935C-845C2AFF7112 FormatName:DIRECT=SPX: NetworkNumber; HostNumber\QueueName FormatName:DIRECT=TCP: IPAddress\QueueName FormatName:DIRECT=OS: MachineName\QueueName
ラベル	Label: [ label ]	Label: TheLabel

参照

構文

例

書式名

FormatName: [ format name ]

FormatName:Public= 5A5F7535-AE9A-41d4-935C-845C2AFF7112

FormatName:DIRECT=SPX: NetworkNumber; HostNumber\QueueName

FormatName:DIRECT=TCP: IPAddress\QueueName

FormatName:DIRECT=OS: MachineName\QueueName

ラベル

Label: [ label ]

Label: TheLabel

オフラインで作業をするには、パス名構文ではなく書式名構文をコンストラクタで使用する必要があります。パス名構文を使用すると、パスを書式名に解決するプライマリドメインコントローラが利用できないため、例外がスローされます。

MessageQueue のインスタンスの初期プロパティ値を次の表に示します。これらの値は、path パラメータで指定されたパスのメッセージキューのキュープロパティに基づきます。

プロパティ	初期値
Authenticate	false
BasePriority	0
Category	Empty
DefaultPropertiesToSend	DefaultPropertiesToSend クラスの既定のコンストラクタで設定される値。
EncryptionRequired	メッセージキューのキューのプライバシレベル設定が "Body" の場合は true。それ以外の場合は false。
Formatter	XmlMessageFormatter
Label	Empty
MachineName	メッセージキューのキューのコンピュータ名プロパティの値。
MaximumJournalSize	InfiniteQueueSize
MaximumQueueSize	InfiniteQueueSize
MessageReadPropertyFilter	MessagePropertyFilter クラスの既定のコンストラクタで設定される値。
Path	コンストラクタで設定しない場合は Empty。
QueueName	コンストラクタで設定しない場合は Empty。
DenySharedReceive	false
UseJournalQueue	メッセージキューオブジェクトの履歴設定が有効な場合は true。それ以外の場合は false。

Windows Mobile for Pocket PC、Windows Mobile for Smartphone、Windows CE プラットフォームメモ : デバイスで Active Directory がサポートされないため、.NET Compact Framework ではリモートキューがトランザクションかどうかを確認できません。リモートトランザクションキューにメッセージを送信するには、コンストラクタに渡す path パラメータに ;XACTONLY を付加します。詳細については、「.NET Compact Framework の MSMQ」を参照してください。

使用例

さまざまな種類のパス名構文を使用して、新しい MessageQueue オブジェクトを作成するコード例を次に示します。いずれの場合も、コンストラクタでパスが定義されているキューにメッセージを送信します。

Visual Basic

Imports System
Imports System.Messaging

Public Class MyNewQueue


        
        ' Provides an entry point into the application.
        '         
        ' This example demonstrates several ways to set
        ' a queue's path.
        

        Public Shared Sub
 Main()

            ' Create a new instance of the class.
            Dim myNewQueue As New
 MyNewQueue()

            myNewQueue.SendPublic()
            myNewQueue.SendPrivate()
            myNewQueue.SendByLabel()
            myNewQueue.SendByFormatName()
            myNewQueue.MonitorComputerJournal()
            myNewQueue.MonitorQueueJournal()
            myNewQueue.MonitorDeadLetter()
            myNewQueue.MonitorTransactionalDeadLetter()

            Return

        End Sub 'Main


        ' References public queues.
        Public Sub SendPublic()

            Dim myQueue As New
 MessageQueue(".\myQueue")
            myQueue.Send("Public queue by path name.")

            Return

        End Sub 'SendPublic


        ' References private queues.
        Public Sub SendPrivate()

            Dim myQueue As New
 MessageQueue(".\Private$\myQueue")
            myQueue.Send("Private queue by path name.")

            Return

        End Sub 'SendPrivate


        ' References queues by label.
        Public Sub SendByLabel()

            Dim myQueue As New
 MessageQueue("Label:TheLabel")
            myQueue.Send("Queue by label.")

            Return

        End Sub 'SendByLabel


        ' References queues by format name.
        Public Sub SendByFormatName()

            Dim myQueue As New
 _
                MessageQueue("FormatName:Public="
 + _
                    "5A5F7535-AE9A-41d4-935C-845C2AFF7112")
            myQueue.Send("Queue by format name.")

            Return

        End Sub 'SendByFormatName


        ' References computer journal queues.
        Public Sub MonitorComputerJournal()

            Dim computerJournal As New
 MessageQueue(".\Journal$")

            While True

                Dim journalMessage As Message
 = _
                    computerJournal.Receive()

                ' Process the journal message.

            End While

            Return
        End Sub 'MonitorComputerJournal


        ' References queue journal queues.
        Public Sub MonitorQueueJournal()

            Dim queueJournal As New
 _
                            MessageQueue(".\myQueue\Journal$")

            While True

                Dim journalMessage As Message
 = _
                    queueJournal.Receive()

                ' Process the journal message.

            End While

            Return
        End Sub 'MonitorQueueJournal


        ' References dead-letter queues.
        Public Sub MonitorDeadLetter()
            Dim deadLetter As New
 MessageQueue(".\DeadLetter$")

            While True

                Dim deadMessage As Message
 = deadLetter.Receive()

                ' Process the dead-letter message.

            End While

            Return

        End Sub 'MonitorDeadLetter


        ' References transactional dead-letter queues.
        Public Sub MonitorTransactionalDeadLetter()

            Dim TxDeadLetter As New
 MessageQueue(".\XactDeadLetter$")

            While True

                Dim txDeadLetterMessage As
 Message = _
                    TxDeadLetter.Receive()

                ' Process the transactional dead-letter message.

            End While

            Return

        End Sub 'MonitorTransactionalDeadLetter

End Class 'MyNewQueue

C#

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 demonstrates several ways to set
        // a queue's path.
        //**************************************************

        public static void
 Main()
        {
            // Create a new instance of the class.
            MyNewQueue myNewQueue = new MyNewQueue();

            myNewQueue.SendPublic();
            myNewQueue.SendPrivate();
            myNewQueue.SendByLabel();
            myNewQueue.SendByFormatName();
            myNewQueue.MonitorComputerJournal();
            myNewQueue.MonitorQueueJournal();
            myNewQueue.MonitorDeadLetter();
            myNewQueue.MonitorTransactionalDeadLetter();

            return;
        }
        
        // References public queues.
        public void SendPublic()
        {
            MessageQueue myQueue = new MessageQueue(".\\myQueue");
            myQueue.Send("Public queue by path name.");

            return;
        }

        // References private queues.
        public void SendPrivate()
        {
            MessageQueue myQueue = new 
                MessageQueue(".\\Private$\\myQueue");
            myQueue.Send("Private queue by path name.");

            return;
        }

        // References queues by label.
        public void SendByLabel()
        {
            MessageQueue myQueue = new MessageQueue("Label:TheLabel");
            myQueue.Send("Queue by label.");

            return;
        }

        // References queues by format name.
        public void SendByFormatName()
        {
            MessageQueue myQueue = new 
                MessageQueue("FormatName:Public=5A5F7535-AE9A-41d4" + 
                "-935C-845C2AFF7112");
            myQueue.Send("Queue by format name.");

            return;
        }

        // References computer journal queues.
        public void MonitorComputerJournal()
        {
            MessageQueue computerJournal = new 
                MessageQueue(".\\Journal$");
            while(true)
            {
                Message journalMessage = computerJournal.Receive();
                // Process the journal message.
            }
        }

        // References queue journal queues.
        public void MonitorQueueJournal()
        {
            MessageQueue queueJournal = new 
                MessageQueue(".\\myQueue\\Journal$");
            while(true)
            {
                Message journalMessage = queueJournal.Receive();
                // Process the journal message.
            }
        }
        
        // References dead-letter queues.
        public void MonitorDeadLetter()
        {
            MessageQueue deadLetter = new 
                MessageQueue(".\\DeadLetter$");
            while(true)
            {
                Message deadMessage = deadLetter.Receive();
                // Process the dead-letter message.
            }
        }

        // References transactional dead-letter queues.
        public void MonitorTransactionalDeadLetter()
        {
            MessageQueue TxDeadLetter = new 
                MessageQueue(".\\XactDeadLetter$");
            while(true)
            {
                Message txDeadLetter = TxDeadLetter.Receive();
                // Process the transactional dead-letter message.
            }
        }

    }
}

C++

#using <system.dll>
#using <system.messaging.dll>

using namespace System;
using namespace System::Messaging;
ref class MyNewQueue
{
public:

   // References public queues.
   void SendPublic()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );
      myQueue->Send( "Public queue by path name." );
      return;
   }


   // References private queues.
   void SendPrivate()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\Private$\\myQueue"
 );
      myQueue->Send( "Private queue by path name." );
      return;
   }


   // References queues by label.
   void SendByLabel()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( "Label:TheLabel" );
      myQueue->Send( "Queue by label." );
      return;
   }


   // References queues by format name.
   void SendByFormatName()
   {
      MessageQueue^ myQueue = gcnew MessageQueue( "FormatName:Public=5A5F7535-AE9A-41d4
 -935C-845C2AFF7112" );
      myQueue->Send( "Queue by format name." );
      return;
   }


   // References computer journal queues.
   void MonitorComputerJournal()
   {
      MessageQueue^ computerJournal = gcnew MessageQueue( ".\\Journal$"
 );
      while ( true )
      {
         Message^ journalMessage = computerJournal->Receive();
         
         // Process the journal message.
      }
   }


   // References queue journal queues.
   void MonitorQueueJournal()
   {
      MessageQueue^ queueJournal = gcnew MessageQueue( ".\\myQueue\\Journal$"
 );
      while ( true )
      {
         Message^ journalMessage = queueJournal->Receive();
         
         // Process the journal message.
      }
   }


   // References dead-letter queues.
   void MonitorDeadLetter()
   {
      MessageQueue^ deadLetter = gcnew MessageQueue( ".\\DeadLetter$" );
      while ( true )
      {
         Message^ deadMessage = deadLetter->Receive();
         
         // Process the dead-letter message.
      }
   }


   // References transactional dead-letter queues.
   void MonitorTransactionalDeadLetter()
   {
      MessageQueue^ TxDeadLetter = gcnew MessageQueue( ".\\XactDeadLetter$"
 );
      while ( true )
      {
         Message^ txDeadLetter = TxDeadLetter->Receive();
         
         // Process the transactional dead-letter message.
      }
   }

};


//*************************************************
// Provides an entry point into the application.
//         
// This example demonstrates several ways to set
// a queue's path.
//*************************************************
int main()
{
   
   // Create a new instance of the class.
   MyNewQueue^ myNewQueue = gcnew MyNewQueue;
   myNewQueue->SendPublic();
   myNewQueue->SendPrivate();
   myNewQueue->SendByLabel();
   myNewQueue->SendByFormatName();
   myNewQueue->MonitorComputerJournal();
   myNewQueue->MonitorQueueJournal();
   myNewQueue->MonitorDeadLetter();
   myNewQueue->MonitorTransactionalDeadLetter();
   return 0;
}

J#

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 demonstrates several ways to set
    // a queue's path.
    //**************************************************
    public static void main(String[]
 args)
    {
        // Create a new instance of the class.
        MyNewQueue myNewQueue = new MyNewQueue();

        myNewQueue.SendPublic();
        myNewQueue.SendPrivate();
        myNewQueue.SendByLabel();
        myNewQueue.SendByFormatName();
        myNewQueue.MonitorComputerJournal();
        myNewQueue.MonitorQueueJournal();
        myNewQueue.MonitorDeadLetter();
        myNewQueue.MonitorTransactionalDeadLetter();

        return;
    } //main

    // References public queues.
    public void SendPublic()
    {
        MessageQueue myQueue = new MessageQueue(".\\myQueue");
        myQueue.Send("Public queue by path name.");
        return;
    } //SendPublic

    // References private queues.
    public void SendPrivate()
    {
        MessageQueue myQueue = new MessageQueue(".\\Private$\\myQueue");
        myQueue.Send("Private queue by path name.");
        return;
    } //SendPrivate

    // References queues by label.
    public void SendByLabel()
    {
        MessageQueue myQueue = new MessageQueue("Label:TheLabel");
        myQueue.Send("Queue by label.");
        return;
    } //SendByLabel

    // References queues by format name.
    public void SendByFormatName()
    {
        MessageQueue myQueue =
            new MessageQueue("FormatName:Public=5A5F7535-AE9A-41d4"
            + "-935C-845C2AFF7112");
        myQueue.Send("Queue by format name.");
        return;
    } //SendByFormatName

    // References computer journal queues.
    public void MonitorComputerJournal()
    {
        MessageQueue computerJournal = new MessageQueue(".\\Journal$");
        while (true) {
            Message journalMessage = computerJournal.Receive();
            // Process the journal message.
        }
    } //MonitorComputerJournal

    // References queue journal queues.
    public void MonitorQueueJournal()
    {
        MessageQueue queueJournal = new MessageQueue(".\\myQueue\\Journal$");
        while (true) {
            Message journalMessage = queueJournal.Receive();
            // Process the journal message.
        }
    } //MonitorQueueJournal

    // References dead-letter queues.
    public void MonitorDeadLetter()
    {
        MessageQueue deadLetter = new MessageQueue(".\\DeadLetter$");
        while (true) {
            Message deadMessage = deadLetter.Receive();
            // Process the dead-letter message.
        }
    } //MonitorDeadLetter

    // References transactional dead-letter queues.
    public void MonitorTransactionalDeadLetter()
    {
        MessageQueue objTxDeadLetter = new MessageQueue(".\\XactDeadLetter$");
        while (true) {
            Message txDeadLetter = objTxDeadLetter.Receive();
            // Process the transactional dead-letter message.
        }
    } //MonitorTransactionalDeadLetter
} //MyNewQueue

.NET Framework のセキュリティ

直前の呼び出し元に対する完全な信頼。このメンバは、部分的に信頼されているコードから使用することはできません。詳細については、「」を参照してください。

プラットフォーム

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 によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。

バージョン情報

.NET Framework
サポート対象 : 2.0、1.1、1.0
.NET Compact Framework
サポート対象 : 2.0

参照

関連項目
MessageQueue クラス
MessageQueue メンバ
System.Messaging 名前空間
FormatName
Label
QueueName
Path

指定した読み取りアクセス制限を持つ指定したパスのメッセージキューのキューを参照する MessageQueue クラスの新しいインスタンスを初期化します。

名前空間: System.Messaging
アセンブリ: System.Messaging (system.messaging.dll 内)
構文

Visual Basic (宣言)

Public Sub New ( _
    path As String, _
    sharedModeDenyReceive As Boolean _
)

Visual Basic (使用法)

Dim path As String
Dim sharedModeDenyReceive As Boolean

Dim instance As New MessageQueue(path,
 sharedModeDenyReceive)

C#

public MessageQueue (
    string path,
    bool sharedModeDenyReceive
)

C++

public:
MessageQueue (
    String^ path, 
    bool sharedModeDenyReceive
)

J#

public MessageQueue (
    String path, 
    boolean sharedModeDenyReceive
)

JScript

public function MessageQueue (
    path : String, 
    sharedModeDenyReceive : boolean
)

パラメータ

path: この MessageQueue が参照するキューの場所。ローカルコンピュータの場合は "." にできます。このパラメータの正しい構文の詳細については、「解説」を参照してください。

sharedModeDenyReceive: キューにアクセスする最初のアプリケーションに排他読み取りアクセス許可を与える場合は true。それ以外の場合は false。

例外

例外の種類	条件
ArgumentException	Path プロパティが無効です。設定されていない可能性があります。

解説

パス、書式名、ラベルが判明している、メッセージキューの特定のキューに新しい MessageQueue を結び付ける場合は、このオーバーロードを使用します。キューを参照する最初のアプリケーションに排他アクセス許可を与える場合は、sharedModeDenyReceive パラメータに true を設定します。それ以外の場合は、sharedModeDenyReceive に false を設定するか、path パラメータだけを指定するコンストラクタを使用します。

sharedModeDenyReceive に true を設定すると、他のアプリケーションも含めて、そのメッセージキューのキューにアクセスするすべてのオブジェクトが影響を受けます。パラメータの影響は、このアプリケーションだけにとどまりません。

MessageQueue コンストラクタは MessageQueue クラスの新しいインスタンスを作成します。メッセージキューの新しいキューは作成しません。メッセージキューに新しいキューを作成するには、Create(String) を使用します。

path パラメータの構文は、キューの種類によって異なります。

キューの種類	構文
パブリックキュー	MachineName\QueueName
プライベートキュー	MachineName\Private$\QueueName
ジャーナルキュー	MachineName\QueueName\Journal$
コンピュータの履歴キュー	MachineName\Journal$
コンピュータ配信不能キュー	MachineName\Deadletter$
コンピュータトランザクション配信不能キュー	MachineName\XactDeadletter$

メッセージキューのキューの書式名またはラベルを使用してキューのパスを記述することもできます。

参照	構文	例
書式名	FormatName: [ format name ]	FormatName:Public= 5A5F7535-AE9A-41d4-935C-845C2AFF7112 FormatName:DIRECT=SPX: NetworkNumber; HostNumber\QueueName FormatName:DIRECT=TCP: IPAddress\QueueName FormatName:DIRECT=OS: MachineName\QueueName
ラベル	Label: [ label ]	Label: TheLabel

参照

構文

例

書式名

FormatName: [ format name ]

FormatName:Public= 5A5F7535-AE9A-41d4-935C-845C2AFF7112

FormatName:DIRECT=SPX: NetworkNumber; HostNumber\QueueName

FormatName:DIRECT=TCP: IPAddress\QueueName

FormatName:DIRECT=OS: MachineName\QueueName

ラベル

Label: [ label ]

Label: TheLabel

オフラインで作業をするには、表示名の構文ではなく書式名構文を使用する必要があります。表示名の構文を使用すると、パスを書式名に解決するプライマリドメインコントローラ (Active Directory が常駐) が利用できないため、例外がスローされます

MessageQueue が sharedModeDenyReceive パラメータに true を設定してキューを開くと、そのキューから読み取ろうとするあらゆる MessageQueue は、共有違反のため MessageQueueException を生成します。既に MessageQueue が非排他モードでキューにアクセスしているときに、別の MessageQueue が排他モードでそのキューにアクセスしようとした場合にも、MessageQueueException がスローされます。

MessageQueue のインスタンスの初期プロパティ値を次の表に示します。これらの値は、path パラメータで指定されたパスのメッセージキューのキュープロパティに基づきます。

プロパティ	初期値
Authenticate	false
BasePriority	0
Category	Empty
DefaultPropertiesToSend	DefaultPropertiesToSend クラスの既定のコンストラクタで設定される値。
EncryptionRequired	メッセージキューのキューのプライバシレベル設定が "Body" の場合は true。それ以外の場合は false。
Formatter	XmlMessageFormatter
Label	Empty
MachineName	メッセージキューのキューのコンピュータ名プロパティの値。
MaximumJournalSize	InfiniteQueueSize
MaximumQueueSize	InfiniteQueueSize
MessageReadPropertyFilter	MessagePropertyFilter クラスの既定のコンストラクタで設定される値。
Path	コンストラクタで設定しない場合は Empty。
QueueName	コンストラクタで設定しない場合は Empty。
DenySharedReceive	sharedModeDenyReceive パラメータの値。
UseJournalQueue	メッセージキューオブジェクトの履歴設定が有効な場合は true。それ以外の場合は false。

使用例

新しい MessageQueue を排他アクセスで作成し、パスを設定し、メッセージをキューに送信するコード例を次に示します。

Visual Basic

Imports System
Imports System.Messaging

Public Class MyNewQueue


        ' Provides an entry point into the application.
        '         
        ' This example connects to a message queue, and
        ' requests exclusive read access to the queue.
 

        Public Shared Sub
 Main()

            ' Create a new instance of the class.
            Dim myNewQueue As New
 MyNewQueue()

            ' Output the count of Lowest priority messages.
            myNewQueue.GetExclusiveAccess()

            Return

        End Sub 'Main


  
        ' Requests exlusive read access to the queue. If
        ' access is granted, receives a message from the 
        ' queue.
  

        Public Sub GetExclusiveAccess()

            Try

                ' Request exclusive read access to the queue.
                Dim myQueue As New
 MessageQueue(".\myQueue", True)

                ' Receive a message. This is where a SharingViolation
 
                ' exception would be thrown.
                Dim myMessage As Message =
 myQueue.Receive()

            Catch e As MessageQueueException

                ' Handle request for denial of exclusive read access.
                If e.MessageQueueErrorCode = _
                    MessageQueueErrorCode.SharingViolation Then

                    Console.WriteLine("Denied exclusive read access.")

                End If

                ' Handle other sources of a MessageQueueException.

                ' Handle other exceptions as necessary.

            End Try

            Return

        End Sub 'GetExclusiveAccess

End Class 'MyNewQueue

C#

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 connects to a message queue, and
        // requests exclusive read access to the queue.
        //**************************************************

        public static void
 Main()
        {
            // Create a new instance of the class.
            MyNewQueue myNewQueue = new MyNewQueue();

            // Output the count of Lowest priority messages.
            myNewQueue.GetExclusiveAccess();
                        
            return;
        }


        //**************************************************
        // Requests exlusive read access to the queue. If
        // access is granted, receives a message from the 
        // queue.
        //**************************************************
        
        public void GetExclusiveAccess()
        {
            try
            {
                // Request exclusive read access to the queue.
                MessageQueue myQueue = new 
                    MessageQueue(".\\myQueue", true);

                // Receive a message. This is where SharingViolation
 
                // exceptions would be thrown.
                Message myMessage = myQueue.Receive();
            }
            
            catch (MessageQueueException e)
            {
                // Handle request for denial of exclusive read access.
                if (e.MessageQueueErrorCode == 
                    MessageQueueErrorCode.SharingViolation)
                {
                    Console.WriteLine("Denied exclusive read access");
                }

                // Handle other sources of a MessageQueueException.
            }

            // Handle other exceptions as necessary.

            return;
        }
    }
}

C++

#using <system.dll>
#using <system.messaging.dll>

using namespace System;
using namespace System::Messaging;
ref class MyNewQueue
{
public:

   // Requests exlusive read access to the queue. If
   // access is granted, receives a message from the 
   // queue.
   void GetExclusiveAccess()
   {
      try
      {
         
         // Request exclusive read access to the queue.
         MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue",true
 );
         
         // Receive a message. This is where SharingViolation 
         // exceptions would be thrown.
         Message^ myMessage = myQueue->Receive();
      }
      catch ( MessageQueueException^ e ) 
      {
         
         // Handle request for denial of exclusive read access.
         if ( e->MessageQueueErrorCode == MessageQueueErrorCode::SharingViolation
 )
         {
            Console::WriteLine( "Denied exclusive read access" );
         }

         
         // Handle other sources of a MessageQueueException.
      }

      
      // Handle other exceptions as necessary.
      return;
   }

};


// Provides an entry point into the application.
// This example connects to a message queue, and
// requests exclusive read access to the queue.
int main()
{
   
   // Create a new instance of the class.
   MyNewQueue^ myNewQueue = gcnew MyNewQueue;
   
   // Output the count of Lowest priority messages.
   myNewQueue->GetExclusiveAccess();
   return 0;
}

J#

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 connects to a message queue, and
    // requests exclusive read access to the queue.
    //**************************************************
    public static void main(String[]
 args)
    {
        // Create a new instance of the class.
        MyNewQueue myNewQueue = new MyNewQueue();
        // Output the count of Lowest priority messages.
        myNewQueue.GetExclusiveAccess();
        return;
    } //main

    //**************************************************
    // Requests exlusive read access to the queue. If
    // access is granted, receives a message from the 
    // queue.
    //**************************************************
    public void GetExclusiveAccess()
    {
        try {
            // Request exclusive read access to the queue.
            MessageQueue myQueue = new MessageQueue(".\\myQueue",
 true);
            // Receive a message.This is where SharingViolation 
            // exceptions would be thrown.
            Message myMessage = myQueue.Receive();
        }
        catch (MessageQueueException e) {
            // Handle request for denial of exclusive read access.
            if (e.get_MessageQueueErrorCode().
                Equals(MessageQueueErrorCode.SharingViolation)) {
                Console.WriteLine("Denied exclusive read access");
            }
            // Handle other sources of a MessageQueueException.
        }        
        // Handle other exceptions as necessary.
        return;
    } //GetExclusiveAccess
} //MyNewQueue

.NET Framework のセキュリティ

直前の呼び出し元に対する完全な信頼。このメンバは、部分的に信頼されているコードから使用することはできません。詳細については、「」を参照してください。

プラットフォーム

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 によってサポートされていないバージョンがあります。サポートされているバージョンについては、「システム要件」を参照してください。

バージョン情報

.NET Framework
サポート対象 : 2.0、1.1、1.0
.NET Compact Framework
サポート対象 : 2.0

参照

関連項目
MessageQueue クラス
MessageQueue メンバ
System.Messaging 名前空間
FormatName
Label
Path
QueueName
DenySharedReceive

メモ : このコンストラクタは、.NET Framework version 2.0 で新しく追加されたものです。

MessageQueue クラスの新しいインスタンスを初期化します。

名前空間: System.Messaging
アセンブリ: System.Messaging (system.messaging.dll 内)
構文

Visual Basic (宣言)

Public Sub New ( _
    path As String, _
    sharedModeDenyReceive As Boolean, _
    enableCache As Boolean _
)

Visual Basic (使用法)

Dim path As String
Dim sharedModeDenyReceive As Boolean
Dim enableCache As Boolean

Dim instance As New MessageQueue(path,
 sharedModeDenyReceive, enableCache)

C#

public MessageQueue (
    string path,
    bool sharedModeDenyReceive,
    bool enableCache
)

C++

public:
MessageQueue (
    String^ path, 
    bool sharedModeDenyReceive, 
    bool enableCache
)

J#

public MessageQueue (
    String path, 
    boolean sharedModeDenyReceive, 
    boolean enableCache
)

JScript

public function MessageQueue (
    path : String, 
    sharedModeDenyReceive : boolean, 
    enableCache : boolean
)

パラメータ

path: この MessageQueue が参照するキューの場所。ローカルコンピュータの場合は "." にできます。

sharedModeDenyReceive: キューにアクセスする最初のアプリケーションに排他読み取りアクセス許可を与える場合は true。それ以外の場合は false。

enableCache: 接続キャッシュを作成し、使用する場合は true。それ以外の場合は false。

使用例

排他読み取りアクセスで、接続キャッシュを有効にして、新しい MessageQueue を作成するコード例を次に示します。

C#

// Connect to a queue on the local computer, grant exclusive read
// access to the first application that accesses the queue, and
// enable connection caching.
MessageQueue queue = new MessageQueue(".\\exampleQueue",
 true, true);

C++

// Connect to a queue on the local computer, grant exclusive read
// access to the first application that accesses the queue, and
// enable connection caching.
MessageQueue^ queue = gcnew MessageQueue(".\\exampleQueue", true,
 true);

queue->Close();

J#

// Connect to a queue on the local computer, grant exclusive read
// access to the first application that accesses the queue, and
// enable connection caching.
MessageQueue queue = new MessageQueue(".\\exampleQueue",
 true, true);

.NET Framework のセキュリティ

直前の呼び出し元に対する完全な信頼。このメンバは、部分的に信頼されているコードから使用することはできません。詳細については、「」を参照してください。

プラットフォーム

バージョン情報

.NET Framework
サポート対象 : 2.0

参照

関連項目
MessageQueue クラス
MessageQueue メンバ
System.Messaging 名前空間

メモ : このコンストラクタは、.NET Framework version 2.0 で新しく追加されたものです。

MessageQueue クラスの新しいインスタンスを初期化します。

名前空間: System.Messaging
アセンブリ: System.Messaging (system.messaging.dll 内)
構文

Visual Basic (宣言)

Public Sub New ( _
    path As String, _
    accessMode As QueueAccessMode _
)

Visual Basic (使用法)

Dim path As String
Dim accessMode As QueueAccessMode

Dim instance As New MessageQueue(path,
 accessMode)

C#

public MessageQueue (
    string path,
    QueueAccessMode accessMode
)

C++

public:
MessageQueue (
    String^ path, 
    QueueAccessMode accessMode
)

J#

public MessageQueue (
    String path, 
    QueueAccessMode accessMode
)

JScript

public function MessageQueue (
    path : String, 
    accessMode : QueueAccessMode
)

パラメータ

path: この MessageQueue が参照するキューの場所。ローカルコンピュータの場合は "." にできます。

accessMode: QueueAccessMode 値の 1 つ。

.NET Framework のセキュリティ

直前の呼び出し元に対する完全な信頼。このメンバは、部分的に信頼されているコードから使用することはできません。詳細については、「」を参照してください。

プラットフォーム

バージョン情報

.NET Framework
サポート対象 : 2.0

参照

関連項目
MessageQueue クラス
MessageQueue メンバ
System.Messaging 名前空間

メモ : このコンストラクタは、.NET Framework version 2.0 で新しく追加されたものです。

MessageQueue クラスの新しいインスタンスを初期化します。

名前空間: System.Messaging
アセンブリ: System.Messaging (system.messaging.dll 内)
構文

Visual Basic (宣言)

Public Sub New ( _
    path As String, _
    sharedModeDenyReceive As Boolean, _
    enableCache As Boolean, _
    accessMode As QueueAccessMode _
)

Visual Basic (使用法)

Dim path As String
Dim sharedModeDenyReceive As Boolean
Dim enableCache As Boolean
Dim accessMode As QueueAccessMode

Dim instance As New MessageQueue(path,
 sharedModeDenyReceive, enableCache, accessMode)

C#

public MessageQueue (
    string path,
    bool sharedModeDenyReceive,
    bool enableCache,
    QueueAccessMode accessMode
)

C++

public:
MessageQueue (
    String^ path, 
    bool sharedModeDenyReceive, 
    bool enableCache, 
    QueueAccessMode accessMode
)

J#

public MessageQueue (
    String path, 
    boolean sharedModeDenyReceive, 
    boolean enableCache, 
    QueueAccessMode accessMode
)

JScript

public function MessageQueue (
    path : String, 
    sharedModeDenyReceive : boolean, 
    enableCache : boolean, 
    accessMode : QueueAccessMode
)

パラメータ

path: この MessageQueue が参照するキューの場所。ローカルコンピュータの場合は "." にできます。

sharedModeDenyReceive: キューにアクセスする最初のアプリケーションに排他読み取りアクセス許可を与える場合は true。それ以外の場合は false。

enableCache: 接続キャッシュを作成し、使用する場合は true。それ以外の場合は false。

accessMode: QueueAccessMode 値の 1 つ。

.NET Framework のセキュリティ

直前の呼び出し元に対する完全な信頼。このメンバは、部分的に信頼されているコードから使用することはできません。詳細については、「」を参照してください。

プラットフォーム

バージョン情報

.NET Framework
サポート対象 : 2.0

参照

関連項目
MessageQueue クラス
MessageQueue メンバ
System.Messaging 名前空間

MessageQueue クラスの新しいインスタンスを初期化します。
オーバーロードの一覧

名前	説明
MessageQueue ()	MessageQueue クラスの新しいインスタンスを初期化します。既定のコンストラクタが新しいインスタンスを初期化した後、そのインスタンスを使用する前にインスタンスの Path プロパティを設定する必要があります。 .NET Compact Framework によってサポートされています。
MessageQueue (String)	指定したパスのメッセージキューのキューを参照する MessageQueue クラスの新しいインスタンスを初期化します。 .NET Compact Framework によってサポートされています。
MessageQueue (String, Boolean)	指定した読み取りアクセス制限を持つ指定したパスのメッセージキューのキューを参照する MessageQueue クラスの新しいインスタンスを初期化します。 .NET Compact Framework によってサポートされています。
MessageQueue (String, QueueAccessMode)	MessageQueue クラスの新しいインスタンスを初期化します。
MessageQueue (String, Boolean, Boolean)	MessageQueue クラスの新しいインスタンスを初期化します。
MessageQueue (String, Boolean, Boolean, QueueAccessMode)	MessageQueue クラスの新しいインスタンスを初期化します。

参照

	名前	説明
	AccessMode	キューのアクセスモードを示す値を取得します。
	Authenticate	キューが認証済みメッセージだけを受け入れるかどうかを示す値を取得または設定します。
	Container	Component を格納している IContainer を取得します。 ( Component から継承されます。)
	Site	Component の ISite を取得または設定します。 ( Component から継承されます。)
	WriteHandle	メッセージキューにメッセージを送信するときに使用するネイティブハンドルを取得します。

	名前	説明
	CanRaiseEvents	コンポーネントがイベントを発生させることがきるかどうかを示す値を取得します。 ( Component から継承されます。)
	DesignMode	Component が現在デザインモードかどうかを示す値を取得します。 ( Component から継承されます。)
	Events	Component に結び付けられているイベントハンドラのリストを取得します。 ( Component から継承されます。)

	名前	説明
	BeginPeek	オーバーロードされます。メッセージのピークを開始し、完了したときにイベントハンドラに通知するようにメッセージキューに指示して、非同期のピーク操作を実行します。
	BeginReceive	オーバーロードされます。メッセージの受信を開始し、完了したときにイベントハンドラに通知するようにメッセージキューに指示して、非同期の受信操作を実行します。
	ClearConnectionCache	接続キャッシュを消去します。
	Close	MessageQueue で割り当てられたすべてのリソースを解放します。
	Create	オーバーロードされます。メッセージキューサーバーの指定したパスに新しいキューを作成します。
	CreateCursor	現在のメッセージキューの新しい Cursor を作成します。
	CreateObjRef	リモートオブジェクトとの通信に使用するプロキシの生成に必要な情報をすべて格納しているオブジェクトを作成します。 ( MarshalByRefObject から継承されます。)
	Delete	メッセージキューサーバーのキューを削除します。
	Dispose	オーバーロードされます。 MessageQueue で使用されていたリソース (メモリを除く) を解放します。
	EndPeek	指定した非同期のピーク操作を完了します。
	EndReceive	指定した非同期の受信操作を完了します。
	Equals	オーバーロードされます。 2 つの Object インスタンスが等しいかどうかを判断します。 ( Object から継承されます。)
	Exists	指定したパスにメッセージキューのキューが存在するかどうかを判断します。
	GetAllMessages	キューにあるすべてのメッセージを返します。
	GetEnumerator	キュー内のメッセージを列挙します。GetEnumerator の使用は避けてください。代わりに、GetMessageEnumerator2 を使用してください。
	GetHashCode	特定の型のハッシュ関数として機能します。GetHashCode は、ハッシュアルゴリズムや、ハッシュテーブルのようなデータ構造での使用に適しています。 ( Object から継承されます。)
	GetLifetimeService	対象のインスタンスの有効期間ポリシーを制御する、現在の有効期間サービスオブジェクトを取得します。 ( MarshalByRefObject から継承されます。)
	GetMachineId	この MessageQueue が参照するキューが存在するコンピュータの ID を取得します。
	GetMessageEnumerator	キューにあるすべてのメッセージに対して列挙子オブジェクトを作成します。GetMessageEnumerator の使用は避けてください。代わりに、GetMessageEnumerator2 を使用してください。
	GetMessageEnumerator2	キューにあるすべてのメッセージに対して列挙子オブジェクトを作成します。
	GetMessageQueueEnumerator	オーバーロードされます。列挙子オブジェクトを作成し、ネットワーク上のパブリックキューの動的リストを作成します。
	GetPrivateQueuesByMachine	指定したコンピュータにあるすべてのプライベートキューを取得します。
	GetPublicQueues	オーバーロードされます。ネットワーク上のすべてのパブリックキューを取得します。
	GetPublicQueuesByCategory	指定したカテゴリに属するネットワーク上のすべてのパブリックキューを取得します。
	GetPublicQueuesByLabel	指定したラベルが設定されているネットワーク上のすべてのパブリックキューを取得します。
	GetPublicQueuesByMachine	指定したコンピュータにあるすべてのパブリックキューを取得します。
	GetSecurityContext	この呼び出しの時点で現在のユーザーが MSMQ によって関連付けられているセキュリティコンテキスト (スレッド ID) を取得します。
	GetType	現在のインスタンスの Type を取得します。 ( Object から継承されます。)
	InitializeLifetimeService	対象のインスタンスの有効期間ポリシーを制御する、有効期間サービスオブジェクトを取得します。 ( MarshalByRefObject から継承されます。)
	Peek	オーバーロードされます。キューにある最初のメッセージのコピーを返します。メッセージはキューから削除されません。
	PeekByCorrelationId	オーバーロードされます。指定した相関 ID と一致するメッセージをピークします。
	PeekById	オーバーロードされます。指定したメッセージ ID を持つメッセージのコピーを返します。メッセージはキューから削除されません。
	PeekByLookupId	オーバーロードされます。 MSMQ 3.0 で導入されました。キュー内の特定のメッセージをピークします。メッセージは、参照識別子で指定することも、キューの前後の位置関係で指定することもできます。
	Purge	キューに含まれるすべてのメッセージを削除します。
	Receive	オーバーロードされます。キューにある最初のメッセージを受信し、キューから削除します。
	ReceiveByCorrelationId	オーバーロードされます。指定した相関 ID と一致するメッセージを受信します。
	ReceiveById	オーバーロードされます。指定した ID と一致するメッセージを受信し、キューから削除します。
	ReceiveByLookupId	オーバーロードされます。 MSMQ 3.0 で導入されました。特定のメッセージをキューから受信します。メッセージは、参照識別子で指定することも、キューの前後の位置関係で指定することもできます。
	ReferenceEquals	指定した複数の Object インスタンスが同一かどうかを判断します。 ( Object から継承されます。)
	Refresh	リソースの現在の状態を反映するには、MessageQueue で表されるプロパティを更新します。
	ResetPermissions	アクセス許可リストをオペレーティングシステムの既定値にリセットします。既定のリストに追加したキューのアクセス許可を削除します。
	Send	オーバーロードされます。キューにオブジェクトを送信します。
	SetPermissions	オーバーロードされます。現在のセットにアクセス許可を追加します。キューのプロパティとキューのメッセージにアクセスできるユーザーを制御します。
	ToString	Component の名前を格納している String を返します (存在する場合)。このメソッドはオーバーライドできません。 ( Component から継承されます。)

	名前	説明
	Dispose	オーバーロードされます。オーバーライドされます。 MessageQueue で使用されていたリソース (メモリを除く) を解放します。
	Finalize	Component がガベージコレクションによってクリアされる前に、アンマネージリソースを解放し、その他のクリーンアップ操作を実行します。 ( Component から継承されます。)
	GetService	Component またはその Container で提供されるサービスを表すオブジェクトを返します。 ( Component から継承されます。)
	MemberwiseClone	オーバーロードされます。 ( MarshalByRefObject から継承されます。)

	名前	説明
	AccessMode	キューのアクセスモードを示す値を取得します。
	Authenticate	キューが認証済みメッセージだけを受け入れるかどうかを示す値を取得または設定します。
	Container	Component を格納している IContainer を取得します。(Component から継承されます。)
	Site	Component の ISite を取得または設定します。(Component から継承されます。)
	WriteHandle	メッセージキューにメッセージを送信するときに使用するネイティブハンドルを取得します。

MessageQueueとは？わかりやすく解説

MessageQueue イベント

関連項目

MessageQueue クラス

MessageQueue コンストラクタ ()

MessageQueue コンストラクタ (String)

MessageQueue コンストラクタ (String, Boolean)

MessageQueue コンストラクタ (String, Boolean, Boolean)

MessageQueue コンストラクタ (String, QueueAccessMode)

MessageQueue コンストラクタ (String, Boolean, Boolean, QueueAccessMode)

MessageQueue コンストラクタ

関連項目

MessageQueue フィールド

関連項目

MessageQueue プロパティ

関連項目

MessageQueue メソッド

関連項目

MessageQueue メンバ

関連項目

「MessageQueue」の関連用語

	名前	説明
	CanRaiseEvents	コンポーネントがイベントを発生させることがきるかどうかを示す値を取得します。(Component から継承されます。)
	DesignMode	Component が現在デザインモードかどうかを示す値を取得します。(Component から継承されます。)
	Events	Component に結び付けられているイベントハンドラのリストを取得します。(Component から継承されます。)


	© 2025 Microsoft.All rights reserved.

MessageQueueとは？ わかりやすく解説

MessageQueue イベント

関連項目

MessageQueue クラス

MessageQueue コンストラクタ ()

MessageQueue コンストラクタ (String)

MessageQueue コンストラクタ (String, Boolean)

MessageQueue コンストラクタ (String, Boolean, Boolean)

MessageQueue コンストラクタ (String, QueueAccessMode)

MessageQueue コンストラクタ (String, Boolean, Boolean, QueueAccessMode)

MessageQueue コンストラクタ

関連項目

MessageQueue フィールド

関連項目

MessageQueue プロパティ

関連項目

MessageQueue メソッド

関連項目

MessageQueue メンバ

関連項目

急上昇のことば

「MessageQueue」の関連用語

MessageQueueとは？わかりやすく解説