MessageQueue Класс

Определение

Предоставляет доступ к очереди на сервере MSMQ.Provides access to a queue on a Message Queuing server.

public ref class MessageQueue : System::ComponentModel::Component, System::Collections::IEnumerable
[System.ComponentModel.TypeConverter(typeof(System.Messaging.Design.MessageQueueConverter))]
[System.Messaging.MessagingDescription("MessageQueueDesc")]
public class MessageQueue : System.ComponentModel.Component, System.Collections.IEnumerable
type MessageQueue = class
    inherit Component
    interface IEnumerable
Public Class MessageQueue
Inherits Component
Implements IEnumerable
Наследование
Атрибуты
Реализации

Примеры

В следующем примере кода создаются новые MessageQueue объекты с использованием различных типов синтаксиса имени пути.The following code example creates new MessageQueue objects using various path name syntax types. В каждом случае он отправляет сообщение в очередь, путь которой определен в конструкторе.In each case, it sends a message to the queue whose path is defined in the constructor.

#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;
}

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.
            }
        }

    }
}
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


        ' References public queues.
        Public Sub SendPublic()

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

            Return

        End Sub


        ' References private queues.
        Public Sub SendPrivate()

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

            Return

        End Sub


        ' References queues by label.
        Public Sub SendByLabel()

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

            Return

        End Sub


        ' 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


        ' 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


        ' 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


        ' 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


        ' 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

End Class

Следующий пример кода отправляет сообщение в очередь и получает сообщение из очереди, используя класс для конкретного приложения с именем Order.The following code example sends a message to a queue, and receives a message from a queue, using an application-specific class called Order.

#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;
}
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;
        }
    }
}
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


   
    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


        '
        ' 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


        '
        ' 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

End Class

Комментарии

Технология очередей сообщений позволяет приложениям, работающим в разное время, взаимодействовать через разнородные сети и системы, которые могут быть временно автономными.The Message Queuing technology allows applications running at different times to communicate across heterogeneous networks and systems that might be temporarily offline. Приложения отправляют, получают или считывают (чтение без удаления) сообщения из очередей.Applications send, receive, or peek (read without removing) messages from queues. Служба очереди сообщений является необязательным компонентом Windows 2000Windows 2000 и Windows NT и должна устанавливаться отдельно.Message Queuing is an optional component of Windows 2000Windows 2000 and Windows NT, and must be installed separately.

Класс MessageQueue является оболочкой для очереди сообщений.The MessageQueue class is a wrapper around Message Queuing. Существует несколько версий очереди сообщений, и использование класса MessageQueue может немного различно повлиять на поведение в зависимости от используемой операционной системы.There are multiple versions of Message Queuing, and using the MessageQueue class can result in slightly different behavior, depending on the operating system you are using. Сведения о конкретных функциях каждой версии очереди сообщений см. в разделе «новые возможности очереди сообщений» пакета Platform SDK на сайте MSDN.For information about specific features of each version of Message Queuing, see the topic "What's New in Message Queuing" in the Platform SDK in MSDN.

Класс MessageQueue предоставляет ссылку на очередь очереди сообщений.The MessageQueue class provides a reference to a Message Queuing queue. Можно указать путь в конструкторе MessageQueue, чтобы подключиться к существующему ресурсу, или создать новую очередь на сервере.You can specify a path in the MessageQueue constructor to connect to an existing resource, or you can create a new queue on the server. Прежде чем можно будет вызвать Send(Object), Peekили Receive, необходимо связать новый экземпляр класса MessageQueue с существующей очередью.Before you can call Send(Object), Peek, or Receive, you must associate the new instance of the MessageQueue class with an existing queue. На этом этапе можно манипулировать свойствами очереди, такими как Category и Label.At that point, you can manipulate the queue properties such as Category and Label.

MessageQueue поддерживает два типа извлечения сообщений: синхронные и асинхронные.MessageQueue supports two types of message retrieval: synchronous and asynchronous. Синхронные методы, Peek и Receive, вызывают ожидание потоком процесса заданного интервала времени для поступления нового сообщения в очередь.The synchronous methods, Peek and Receive, cause the process thread to wait a specified time interval for a new message to arrive in the queue. Асинхронные методы, BeginPeek и BeginReceive, позволяют основным задачам приложения продолжать работу в отдельном потоке, пока сообщение не поступит в очередь.The asynchronous methods, BeginPeek and BeginReceive, allow the main application tasks to continue in a separate thread until a message arrives in the queue. Эти методы работают, используя объекты обратного вызова и объекты состояния для обмена данными между потоками.These methods work by using callback objects and state objects to communicate information between threads.

При создании нового экземпляра класса MessageQueue не создается новая очередь очередей сообщений.When you create a new instance of the MessageQueue class, you are not creating a new Message Queuing queue. Вместо этого можно использовать методы Create(String), Delete(String)и Purge для управления очередями на сервере.Instead, you can use the Create(String), Delete(String), and Purge methods to manage queues on the server.

В отличие от Purge, Create(String) и Delete(String) являются static членами, поэтому их можно вызывать без создания нового экземпляра класса MessageQueue.Unlike Purge, Create(String) and Delete(String) are static members, so you can call them without creating a new instance of the MessageQueue class.

Свойство Path объекта MessageQueue можно задать с помощью одного из трех имен: понятное имя, FormatNameили Label.You can set the MessageQueue object's Path property with one of three names: the friendly name, the FormatName, or the Label. Понятное имя, которое определяется свойствами MachineName и QueueName очереди, MachineName\QueueName для общей очереди и MachineName\Private$\QueueName для частной очереди.The friendly name, which is defined by the queue's MachineName and QueueName properties, is MachineName\QueueName for a public queue, and MachineName\Private$\QueueName for a private queue. Свойство FormatName обеспечивает автономный доступ к очередям сообщений.The FormatName property allows offline access to message queues. Наконец, можно использовать свойство Label очереди, чтобы задать Pathочереди.Lastly, you can use the queue's Label property to set the queue's Path.

Список начальных значений свойств для экземпляра MessageQueueсм. в разделе Конструктор MessageQueue.For a list of initial property values for an instance of MessageQueue, see the MessageQueue constructor.

Конструкторы

MessageQueue()

Инициализирует новый экземпляр класса MessageQueue.Initializes a new instance of the MessageQueue class. После того как конструктор без параметров инициализирует новый экземпляр, необходимо задать свойство Path экземпляра, прежде чем можно будет использовать этот экземпляр.After the parameterless constructor initializes the new instance, you must set the instance's Path property before you can use the instance.

MessageQueue(String)

Инициализирует новый экземпляр класса MessageQueue, который ссылается на очередь MSMQ по указанному пути.Initializes a new instance of the MessageQueue class that references the Message Queuing queue at the specified path.

MessageQueue(String, Boolean)

Инициализирует новый экземпляр класса MessageQueue, который ссылается на очередь MSMQ по указанному пути и с указанным ограничением доступа на чтение.Initializes a new instance of the MessageQueue class that references the Message Queuing queue at the specified path and with the specified read-access restriction.

MessageQueue(String, Boolean, Boolean)

Инициализирует новый экземпляр класса MessageQueue.Initializes a new instance of the MessageQueue class.

MessageQueue(String, Boolean, Boolean, QueueAccessMode)

Инициализирует новый экземпляр класса MessageQueue.Initializes a new instance of the MessageQueue class.

MessageQueue(String, QueueAccessMode)

Инициализирует новый экземпляр класса MessageQueue.Initializes a new instance of the MessageQueue class.

Поля

InfiniteQueueSize

Указывает, что для очереди нет ограничений по размеру.Specifies that no size restriction exists for a queue.

InfiniteTimeout

Указывает, что для методов считывания и получения сообщений не существует тайм-аута.Specifies that no time-out exists for methods that peek or receive messages.

Свойства

AccessMode

Получает значение, указывающее режим доступа для очереди.Gets a value that indicates the access mode for the queue.

Authenticate

Получает или задает значение, показывающее, принимает ли очередь только сообщения, прошедшие проверку подлинности.Gets or sets a value that indicates whether the queue accepts only authenticated messages.

BasePriority

Получает или задает базовый приоритет, используемый службой очереди сообщений для маршрутизации сообщений общей очереди по сети.Gets or sets the base priority Message Queuing uses to route a public queue's messages over the network.

CanRaiseEvents

Возвращает значение, показывающее, может ли компонент вызывать событие.Gets a value indicating whether the component can raise an event.

(Унаследовано от Component)
CanRead

Получает значение, указывающее, может ли быть прочитан объект MessageQueue.Gets a value that indicates whether the MessageQueue can be read.

CanWrite

Получает значение, указывающее, может ли быть выполнена запись в MessageQueue.Gets a value that indicates whether the MessageQueue can be written to.

Category

Возвращает или задает категорию очереди.Gets or sets the queue category.

Container

Возвращает контейнер IContainer, содержащий компонент Component.Gets the IContainer that contains the Component.

(Унаследовано от Component)
CreateTime

Получает время и дату создания очереди в службе очереди сообщений.Gets the time and date that the queue was created in Message Queuing.

DefaultPropertiesToSend

Получает или задает значения свойств сообщения, которые будут использоваться по умолчанию, когда приложение будет отправлять сообщения в очередь.Gets or sets the message property values to be used by default when the application sends messages to the queue.

DenySharedReceive

Получает или задает значение, показывающее, имеет ли этот объект MessageQueue монопольный доступ на получение сообщений из очереди сообщений.Gets or sets a value that indicates whether this MessageQueue has exclusive access to receive messages from the Message Queuing queue.

DesignMode

Возвращает значение, указывающее, находится ли данный компонент Component в режиме конструктора в настоящее время.Gets a value that indicates whether the Component is currently in design mode.

(Унаследовано от Component)
EnableConnectionCache

Получает или задает значение, указывающее, будет ли приложение поддерживать кэш подключений.Gets or sets a value that indicates whether a cache of connections will be maintained by the application.

EncryptionRequired

Получает или задает значение, указывающее, будет ли очередь принимать только неконфиденциальные (незашифрованные) сообщения.Gets or sets a value that indicates whether the queue accepts only non-private (non-encrypted) messages.

Events

Возвращает список обработчиков событий, которые прикреплены к этому объекту Component.Gets the list of event handlers that are attached to this Component.

(Унаследовано от Component)
FormatName

Получает уникальное имя очереди, созданное службой очереди сообщений в момент создания очереди.Gets the unique queue name that Message Queuing generated at the time of the queue's creation.

Formatter

Получает или задает модуль форматирования, используемый для сериализации объекта в текст сообщения или десериализации из текста сообщения, прочитанного из очереди или записанного в очередь.Gets or sets the formatter used to serialize an object into or deserialize an object from the body of a message read from or written to the queue.

Id

Получает уникальный идентификатор очереди сообщений.Gets the unique Message Queuing identifier of the queue.

Label

Получает или задает описание очереди.Gets or sets the queue description.

LastModifyTime

Получает время последнего изменения свойств очереди.Gets the last time the properties of a queue were modified.

MachineName

Получает или задает имя компьютера, на котором расположена очередь Message Queuing.Gets or sets the name of the computer where the Message Queuing queue is located.

MaximumJournalSize

Получает или задает максимальный размер очереди журнала.Gets or sets the maximum size of the journal queue.

MaximumQueueSize

Получает или задает максимальный размер очереди.Gets or sets the maximum size of the queue.

MessageReadPropertyFilter

Получает или задает фильтр свойств для получения и считывания сообщений.Gets or sets the property filter for receiving or peeking messages.

MulticastAddress

Представлено в MSMQ 3.0.Introduced in MSMQ 3.0. Получает или задает адрес многоадресной рассылки, связанный с данной очередью.Gets or sets the multicast address associated with the queue.

Path

Получает или задает путь очереди.Gets or sets the queue's path. После задания свойства Path объект MessageQueue будет указывать на новую очередь.Setting the Path causes the MessageQueue to point to a new queue.

QueueName

Получает или задает понятное имя, определяющее очередь.Gets or sets the friendly name that identifies the queue.

ReadHandle

Получает собственный дескриптор, предназначенный для чтения сообщений из очереди сообщений.Gets the native handle used to read messages from the message queue.

Site

Возвращает или задает ISite объекта Component.Gets or sets the ISite of the Component.

(Унаследовано от Component)
SynchronizingObject

Получает или задает объект, который используется для маршалинга вызовов обработчика событий, возникающих в результате наступления события ReceiveCompleted или события PeekCompleted.Gets or sets the object that marshals the event-handler call resulting from a ReceiveCompleted or PeekCompleted event.

Transactional

Получает значение, указывающее, принимает ли очередь только транзакции.Gets a value that indicates whether the queue accepts only transactions.

UseJournalQueue

Получает или задает значение, указывающее, должны ли полученные сообщения копироваться в очередь журнала.Gets or sets a value that indicates whether received messages are copied to the journal queue.

WriteHandle

Получает собственный дескриптор, который используется для отправки сообщений в очередь сообщений.Gets the native handle used to send messages to the message queue.

Методы

BeginPeek()

Инициирует асинхронную операцию считывания, не имеющую тайм-аута. Операция остается незавершенной, пока сообщение не станет доступным в очереди.Initiates an asynchronous peek operation that has no time-out. The operation is not complete until a message becomes available in the queue.

BeginPeek(TimeSpan)

Инициирует асинхронную операцию считывания с заданным тайм-аутом. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.Initiates an asynchronous peek operation that has a specified time-out. The operation is not complete until either a message becomes available in the queue or the time-out occurs.

BeginPeek(TimeSpan, Cursor, PeekAction, Object, AsyncCallback)

Инициирует асинхронную операцию считывания, которая имеет заданный тайм-аут и использует заданный курсор, заданную операцию считывания и заданный объект состояния.Initiates an asynchronous peek operation that has a specified time-out and that uses a specified cursor, a specified peek action, and a specified state object. Объект состояния предоставляет связанные сведения в течение всего времени выполнения операции.The state object provides associated information throughout the lifetime of the operation. Посредством обратного вызова эта перегрузка получает уведомление об отличительных особенностях обработчика событий для операции.This overload receives notification, through a callback, of the identity of the event handler for the operation. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.The operation is not complete until either a message becomes available in the queue or the time-out occurs.

BeginPeek(TimeSpan, Object)

Инициирует асинхронную операцию считывания с указанным тайм-аутом и заданным объектом состояния, который предоставляет связанные данные в течение всего времени выполнения операции.Initiates an asynchronous peek operation that has a specified time-out and a specified state object, which provides associated information throughout the operation's lifetime. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.The operation is not complete until either a message becomes available in the queue or the time-out occurs.

BeginPeek(TimeSpan, Object, AsyncCallback)

Инициирует асинхронную операцию считывания с указанным тайм-аутом и заданным объектом состояния, который предоставляет связанные данные в течение всего времени выполнения операции.Initiates an asynchronous peek operation that has a specified time-out and a specified state object, which provides associated information throughout the operation's lifetime. Посредством обратного вызова эта перегрузка получает уведомление об отличительных особенностях обработчика событий для операции.This overload receives notification, through a callback, of the identity of the event handler for the operation. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.The operation is not complete until either a message becomes available in the queue or the time-out occurs.

BeginReceive()

Инициирует асинхронную операцию получения без тайм-аута. Операция остается незавершенной, пока сообщение не станет доступным в очереди.Initiates an asynchronous receive operation that has no time-out. The operation is not complete until a message becomes available in the queue.

BeginReceive(TimeSpan)

Инициирует асинхронную операцию получения с указанным тайм-аутом. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.Initiates an asynchronous receive operation that has a specified time-out. The operation is not complete until either a message becomes available in the queue or the time-out occurs.

BeginReceive(TimeSpan, Cursor, Object, AsyncCallback)

Инициирует асинхронную операцию получения, которая имеет заданный тайм-аут и использует заданный курсор и заданный объект состояния.Initiates an asynchronous receive operation that has a specified time-out and uses a specified cursor and a specified state object. Объект состояния предоставляет связанные сведения в течение всего времени выполнения операции.The state object provides associated information throughout the lifetime of the operation. Посредством обратного вызова эта перегрузка получает уведомление об отличительных особенностях обработчика событий для операции.This overload receives notification, through a callback, of the identity of the event handler for the operation. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.The operation is not complete until either a message becomes available in the queue or the time-out occurs.

BeginReceive(TimeSpan, Object)

Инициирует асинхронную операцию получения с указанным тайм-аутом и заданным объектом состояния, который предоставляет связанные данные в течение всего времени выполнения операции.Initiates an asynchronous receive operation that has a specified time-out and a specified state object, which provides associated information throughout the operation's lifetime. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.The operation is not complete until either a message becomes available in the queue or the time-out occurs.

BeginReceive(TimeSpan, Object, AsyncCallback)

Инициирует асинхронную операцию получения с указанным тайм-аутом и заданным объектом состояния, который предоставляет связанные данные в течение всего времени выполнения операции.Initiates an asynchronous receive operation that has a specified time-out and a specified state object, which provides associated information throughout the operation's lifetime. Посредством обратного вызова эта перегрузка получает уведомление об отличительных особенностях обработчика событий для операции.This overload receives notification, through a callback, of the identity of the event handler for the operation. Операция остается незавершенной, пока сообщение не станет доступным в очереди или пока не истечет время ожидания.The operation is not complete until either a message becomes available in the queue or the time-out occurs.

ClearConnectionCache()

Очищает кэш подключений.Clears the connection cache.

Close()

Освобождает все ресурсы, выделенные классом MessageQueue.Frees all resources allocated by the MessageQueue.

Create(String)

Создает нетранзакционную очередь сообщений по указанному пути.Creates a non-transactional Message Queuing queue at the specified path.

Create(String, Boolean)

Создает транзакционную или нетранзакционную очередь сообщений по указанному пути.Creates a transactional or non-transactional Message Queuing queue at the specified path.

CreateCursor()

Создает новый объект Cursor для текущей очереди сообщений.Creates a new Cursor for the current message queue.

CreateObjRef(Type)

Создает объект, который содержит всю необходимую информацию для создания прокси-сервера, используемого для взаимодействия с удаленным объектом.Creates an object that contains all the relevant information required to generate a proxy used to communicate with a remote object.

(Унаследовано от MarshalByRefObject)
Delete(String)

Удаляет очередь с сервера очереди сообщений.Deletes a queue on a Message Queuing server.

Dispose()

Освобождает все ресурсы, занятые модулем Component.Releases all resources used by the Component.

(Унаследовано от Component)
Dispose(Boolean)

Уничтожает ресурсы (кроме памяти), используемые классом MessageQueue.Disposes of the resources (other than memory) used by the MessageQueue.

EndPeek(IAsyncResult)

Завершает указанную асинхронную операцию считывания.Completes the specified asynchronous peek operation.

EndReceive(IAsyncResult)

Завершает указанную асинхронную операцию получения.Completes the specified asynchronous receive operation.

Equals(Object)

Определяет, равен ли указанный объект текущему объекту.Determines whether the specified object is equal to the current object.

(Унаследовано от Object)
Exists(String)

Определяет, существует ли по указанному пути очередь сообщений.Determines whether a Message Queuing queue exists at the specified path.

GetAllMessages()

Возвращает все сообщения из очереди.Returns all the messages that are in the queue.

GetEnumerator()

Перечисляет сообщения в очереди.Enumerates the messages in a queue. Параметр GetEnumerator() использовать не рекомендуется.GetEnumerator() is deprecated. Вместо него следует использовать метод GetMessageEnumerator2().GetMessageEnumerator2() should be used instead.

GetHashCode()

Служит в качестве хэш-функции по умолчанию.Serves as the default hash function.

(Унаследовано от Object)
GetLifetimeService()

Извлекает объект обслуживания во время существования, который управляет политикой времени существования данного экземпляра.Retrieves the current lifetime service object that controls the lifetime policy for this instance.

(Унаследовано от MarshalByRefObject)
GetMachineId(String)

Получает идентификатор компьютера, на котором расположена очередь, на которую ссылается этот класс MessageQueue.Gets the identifier of the computer on which the queue referenced by this MessageQueue is located.

GetMessageEnumerator()

Создает объект перечислителя для всех сообщений очереди.Creates an enumerator object for all the messages in the queue. Параметр GetMessageEnumerator() использовать не рекомендуется.GetMessageEnumerator() is deprecated. Вместо него следует использовать метод GetMessageEnumerator2().GetMessageEnumerator2() should be used instead.

GetMessageEnumerator2()

Создает объект перечислителя для всех сообщений очереди.Creates an enumerator object for all the messages in the queue.

GetMessageQueueEnumerator()

Обеспечивает семантику курсора последовательного доступа для перечисления во всех общих очередях сети.Provides forward-only cursor semantics to enumerate through all public queues on the network.

GetMessageQueueEnumerator(MessageQueueCriteria)

Обеспечивает семантику курсора последовательного доступа для перечисления во всех общих очередях сети, удовлетворяющих указанным критериям.Provides forward-only cursor semantics to enumerate through all public queues on the network that meet the specified criteria.

GetPrivateQueuesByMachine(String)

Извлекает все частные очереди на указанном компьютере.Retrieves all the private queues on the specified computer.

GetPublicQueues()

Извлекает все общие очереди сети.Retrieves all the public queues on the network.

GetPublicQueues(MessageQueueCriteria)

Извлекает все общие очереди сети, удовлетворяющие указанным критериям.Retrieves all the public queues on the network that meet the specified criteria.

GetPublicQueuesByCategory(Guid)

Извлекает все общие очереди сети, принадлежащие к указанной категории.Retrieves all the public queues on the network that belong to the specified category.

GetPublicQueuesByLabel(String)

Извлекает все общие очереди сети с указанной меткой.Retrieves all the public queues on the network that carry the specified label.

GetPublicQueuesByMachine(String)

Извлекает все общие очереди, находящиеся на указанном компьютере.Retrieves all the public queues that reside on the specified computer.

GetSecurityContext()

Извлекает контекст безопасности, который служба MSMQ связывает с текущим пользователем (удостоверением потока) на момент этого вызова.Retrieves the security context that MSMQ associates with the current user (thread identity) at the time of this call.

GetService(Type)

Возвращает объект, представляющий службу, обеспечиваемую компонентом Component или его контейнером Container.Returns an object that represents a service provided by the Component or by its Container.

(Унаследовано от Component)
GetType()

Возвращает объект Type для текущего экземпляра.Gets the Type of the current instance.

(Унаследовано от Object)
InitializeLifetimeService()

Получает объект службы времени существования для управления политикой времени существования для этого экземпляра.Obtains a lifetime service object to control the lifetime policy for this instance.

(Унаследовано от MarshalByRefObject)
MemberwiseClone()

Создает неполную копию текущего объекта Object.Creates a shallow copy of the current Object.

(Унаследовано от Object)
MemberwiseClone(Boolean)

Создает неполную копию текущего объекта MarshalByRefObject.Creates a shallow copy of the current MarshalByRefObject object.

(Унаследовано от MarshalByRefObject)
Peek()

Возвращает, не удаляя (считывает), первое сообщение в очереди, на которую ссылается этот объект MessageQueue.Returns without removing (peeks) the first message in the queue referenced by this MessageQueue. Метод Peek() является синхронным, поэтому он блокирует текущий поток до тех пор, пока сообщение не станет доступным.The Peek() method is synchronous, so it blocks the current thread until a message becomes available.

Peek(TimeSpan)

Возвращает, не удаляя (считывает), первое сообщение в очереди, на которую ссылается этот объект MessageQueue.Returns without removing (peeks) the first message in the queue referenced by this MessageQueue. Метод Peek() является синхронным, поэтому он блокирует текущий поток до тех пор, пока сообщение не станет доступным или пока не истечет заданный тайм-аут.The Peek() method is synchronous, so it blocks the current thread until a message becomes available or the specified time-out occurs.

Peek(TimeSpan, Cursor, PeekAction)

Возвращает, не удаляя (считывает), текущее или следующее сообщение в очереди, используя заданный курсор.Returns without removing (peeks) the current or next message in the queue, using the specified cursor. Метод Peek() является синхронным, поэтому он блокирует текущий поток до тех пор, пока сообщение не станет доступным или пока не истечет заданный тайм-аут.The Peek() method is synchronous, so it blocks the current thread until a message becomes available or the specified time-out occurs.

PeekByCorrelationId(String)

Считывает сообщение, которое соответствует заданному идентификатору корреляции, и сразу инициирует исключение, если в настоящий момент в очереди нет сообщения с указанным идентификатором корреляции.Peeks the message that matches the given correlation identifier and immediately raises an exception if no message with the specified correlation identifier currently exists in the queue.

PeekByCorrelationId(String, TimeSpan)

Считывает сообщение, которое соответствует заданному идентификатору корреляции и ожидает, пока в очереди не появится сообщение с указанным идентификатором корреляции или пока не истечет тайм-аут.Peeks the message that matches the given correlation identifier and waits until either a message with the specified correlation identifier is available in the queue, or the time-out expires.

PeekById(String)

Считывает сообщение, идентификатор которого соответствует параметру id.Peeks the message whose message identifier matches the id parameter.

PeekById(String, TimeSpan)

Считывает сообщение, идентификатор которого соответствует параметру id.Peeks the message whose message identifier matches the id parameter. Ожидает, пока сообщение не появится в очереди, или не возникнет тайм-аут.Waits until the message appears in the queue or a time-out occurs.

PeekByLookupId(Int64)

Представлено в MSMQ 3.0.Introduced in MSMQ 3.0. Считывает сообщение, соответствующее заданному идентификатору просмотра, из нетранзакционной очереди.Peeks at the message that matches the given lookup identifier from a non-transactional queue.

PeekByLookupId(MessageLookupAction, Int64)

Представлено в MSMQ 3.0.Introduced in MSMQ 3.0. Считывает конкретное сообщение из очереди.Peeks at a specific message from the queue. Сообщение может быть задано кодом просмотра либо его положением относительно начала или конца очереди.The message can be specified by a lookup identifier or by its position at the front or end of the queue.

Purge()

Удаляет все сообщения, содержащиеся в очереди.Deletes all the messages contained in the queue.

Receive()

Получает первое доступное в очереди сообщение, на которое ссылается объект MessageQueue.Receives the first message available in the queue referenced by the MessageQueue. Этот вызов является синхронным и он блокирует текущий поток выполнения, пока сообщение не станет доступным.This call is synchronous, and blocks the current thread of execution until a message is available.

Receive(MessageQueueTransaction)

Получает первое доступное в транзакционной очереди сообщение, на которое ссылается объект MessageQueue.Receives the first message available in the transactional queue referenced by the MessageQueue. Этот вызов является синхронным и он блокирует текущий поток выполнения, пока сообщение не станет доступным.This call is synchronous, and blocks the current thread of execution until a message is available.

Receive(MessageQueueTransactionType)

Получает первое доступное в очереди сообщение, на которое ссылается объект MessageQueue.Receives the first message available in the queue referenced by the MessageQueue. Этот вызов является синхронным и он блокирует текущий поток выполнения, пока сообщение не станет доступным.This call is synchronous, and blocks the current thread of execution until a message is available.

Receive(TimeSpan)

Получает первое сообщение, доступное в очереди, на которую ссылается объект MessageQueue, и ожидает пока в очереди не появится сообщение или пока не истечет тайм-аут.Receives the first message available in the queue referenced by the MessageQueue and waits until either a message is available in the queue, or the time-out expires.

Receive(TimeSpan, Cursor)

Получает текущее сообщение в очереди, используя заданный курсор.Receives the current message in the queue, using a specified cursor. Если доступных сообщений нет, этот метод ожидает, пока не станет доступным сообщение или пока не истечет тайм-аут.If no message is available, this method waits until either a message is available, or the time-out expires.

Receive(TimeSpan, Cursor, MessageQueueTransaction)

Получает текущее сообщение в очереди, используя заданный курсор.Receives the current message in the queue, using a specified cursor. Если доступных сообщений нет, этот метод ожидает, пока не станет доступным сообщение или пока не истечет тайм-аут.If no message is available, this method waits until either a message is available, or the time-out expires.

Receive(TimeSpan, Cursor, MessageQueueTransactionType)

Получает текущее сообщение в очереди, используя заданный курсор.Receives the current message in the queue, using a specified cursor. Если доступных сообщений нет, этот метод ожидает, пока не станет доступным сообщение или пока не истечет тайм-аут.If no message is available, this method waits until either a message is available, or the time-out expires.

Receive(TimeSpan, MessageQueueTransaction)

Получает первое сообщение, доступное в транзакционной очереди, на которую ссылается объект MessageQueue, и ожидает, пока в очереди не появится сообщение или пока не истечет тайм-аут.Receives the first message available in the transactional queue referenced by the MessageQueue and waits until either a message is available in the queue, or the time-out expires.

Receive(TimeSpan, MessageQueueTransactionType)

Получает первое доступное в очереди сообщение, на которое ссылается объект MessageQueue.Receives the first message available in the queue referenced by the MessageQueue. Данный вызов является синхронным, и он ожидает, пока в очереди не появится сообщение, или пока не истечет тайм-аут.This call is synchronous, and waits until either a message is available in the queue, or the time-out expires.

ReceiveByCorrelationId(String)

Получает сообщение, которое соответствует заданному идентификатору корреляции (из нетранзакционной очереди), и сразу инициирует исключение, если в настоящий момент в очереди нет сообщения с указанным идентификатором корреляции.Receives the message that matches the given correlation identifier (from a non-transactional queue) and immediately raises an exception if no message with the specified correlation identifier currently exists in the queue.

ReceiveByCorrelationId(String, MessageQueueTransaction)

Получает сообщение, которое соответствует заданному идентификатору корреляции (из транзакционной очереди), и сразу инициирует исключение, если в настоящий момент в очереди нет сообщения с указанным идентификатором корреляции.Receives the message that matches the given correlation identifier (from a transactional queue) and immediately raises an exception if no message with the specified correlation identifier currently exists in the queue.

ReceiveByCorrelationId(String, MessageQueueTransactionType)

Получает сообщение, которое соответствует заданному идентификатору корреляции, и сразу инициирует исключение, если в настоящий момент в очереди нет сообщения с указанным идентификатором корреляции.Receives the message that matches the given correlation identifier and immediately raises an exception if no message with the specified correlation identifier currently exists in the queue.

ReceiveByCorrelationId(String, TimeSpan)

Получает сообщение, которое соответствует заданному идентификатору корреляции (из нетранзакционной очереди), и ожидает, пока в очереди не появится сообщение с указанным идентификатором корреляции или пока не истечет тайм-аут.Receives the message that matches the given correlation identifier (from a non-transactional queue) and waits until either a message with the specified correlation identifier is available in the queue, or the time-out expires.

ReceiveByCorrelationId(String, TimeSpan, MessageQueueTransaction)

Получает сообщение, которое соответствует заданному идентификатору корреляции (из транзакционной очереди), и ожидает, пока в очереди не появится сообщение с указанным идентификатором корреляции или пока не истечет тайм-аут.Receives the message that matches the given correlation identifier (from a transactional queue) and waits until either a message with the specified correlation identifier is available in the queue, or the time-out expires.

ReceiveByCorrelationId(String, TimeSpan, MessageQueueTransactionType)

Получает сообщение, которое соответствует заданному идентификатору корреляции и ожидает, пока в очереди не появится сообщение с указанным идентификатором корреляции или пока не истечет тайм-аут.Receives the message that matches the given correlation identifier and waits until either a message with the specified correlation identifier is available in the queue, or the time-out expires.

ReceiveById(String)

Получает из нетранзакционной очереди сообщение, которое соответствует заданному идентификатору, и сразу инициирует исключение, если в настоящий момент в очереди нет сообщения с указанным идентификатором.Receives the message that matches the given identifier from a non-transactional queue and immediately raises an exception if no message with the specified identifier currently exists in the queue.

ReceiveById(String, MessageQueueTransaction)

Получает сообщение, которое соответствует заданному идентификатору (из транзакционной очереди), и сразу инициирует исключение, если в настоящий момент в очереди нет сообщения с указанным идентификатором.Receives the message that matches the given identifier (from a transactional queue) and immediately raises an exception if no message with the specified identifier currently exists in the queue.

ReceiveById(String, MessageQueueTransactionType)

Получает сообщение, которое соответствует заданному идентификатору, и сразу инициирует исключение, если в настоящий момент в очереди нет сообщения с указанным идентификатором.Receives the message that matches the given identifier and immediately raises an exception if no message with the specified identifier currently exists in the queue.

ReceiveById(String, TimeSpan)

Получает сообщение, которое соответствует заданному идентификатору (из нетранзакционной очереди), и ожидает, пока в очереди не появится сообщение с указанным идентификатором, или пока не истечет тайм-аут.Receives the message that matches the given identifier (from a non-transactional queue) and waits until either a message with the specified identifier is available in the queue or the time-out expires.

ReceiveById(String, TimeSpan, MessageQueueTransaction)

Получает сообщение, которое соответствует заданному идентификатору (из транзакционной очереди), и ожидает, пока в очереди не появится сообщение с указанным идентификатором, или пока не истечет тайм-аут.Receives the message that matches the given identifier (from a transactional queue) and waits until either a message with the specified identifier is available in the queue or the time-out expires.

ReceiveById(String, TimeSpan, MessageQueueTransactionType)

Получает сообщение, которое соответствует заданному идентификатору, и ожидает, пока в очереди не появится сообщение с указанным идентификатором, или пока не истечет тайм-аут.Receives the message that matches the given identifier and waits until either a message with the specified identifier is available in the queue or the time-out expires.

ReceiveByLookupId(Int64)

Представлено в MSMQ 3.0.Introduced in MSMQ 3.0. Получает сообщение, соответствующее заданному идентификатору просмотра, из нетранзакционной очереди.Receives the message that matches the given lookup identifier from a non-transactional queue.

ReceiveByLookupId(MessageLookupAction, Int64, MessageQueueTransaction)

Представлено в MSMQ 3.0.Introduced in MSMQ 3.0. Получает конкретное сообщение из транзакционной очереди.Receives a specific message from a transactional queue. Сообщение может быть задано кодом просмотра либо его положением относительно начала или конца очереди.The message can be specified by a lookup identifier or by its position at the front or end of the queue.

ReceiveByLookupId(MessageLookupAction, Int64, MessageQueueTransactionType)

Представлено в MSMQ 3.0.Introduced in MSMQ 3.0. Получает из очереди определенное сообщение, используя заданный контекст транзакции.Receives a specific message from the queue, using the specified transaction context. Сообщение может быть задано кодом просмотра либо его положением относительно начала или конца очереди.The message can be specified by a lookup identifier or by its position at the front or end of the queue.

Refresh()

Обновляет свойства, представленные объектом MessageQueue для отражения текущего состояния ресурса.Refreshes the properties presented by the MessageQueue to reflect the current state of the resource.

ResetPermissions()

Присваивает списку разрешений значения по умолчанию операционной системы.Resets the permission list to the operating system's default values. Удаляет все разрешения очередей, добавленные в список по умолчанию.Removes any queue permissions you have appended to the default list.

Send(Object)

Отправляет объект в нетранзакционную очередь, на которую ссылается этот класс MessageQueue.Sends an object to non-transactional queue referenced by this MessageQueue.

Send(Object, MessageQueueTransaction)

Отправляет объект в транзакционную очередь, на которую ссылается этот объект MessageQueue.Sends an object to the transactional queue referenced by this MessageQueue.

Send(Object, MessageQueueTransactionType)

Отправляет объект в очередь, на которую ссылается этот объект MessageQueue.Sends an object to the queue referenced by this MessageQueue.

Send(Object, String)

Отправляет объект в нетранзакционную очередь, на которую ссылается этот объект MessageQueue, и задает метку сообщения.Sends an object to the non-transactional queue referenced by this MessageQueue and specifies a label for the message.

Send(Object, String, MessageQueueTransaction)

Отправляет объект в транзакционную очередь, на которую ссылается этот объект MessageQueue, и задает метку сообщения.Sends an object to the transactional queue referenced by this MessageQueue and specifies a label for the message.

Send(Object, String, MessageQueueTransactionType)

Отправляет объект в очередь, на которую ссылается этот объект MessageQueue, и задает метку сообщения.Sends an object to the queue referenced by this MessageQueue and specifies a label for the message.

SetPermissions(AccessControlList)

Назначает права доступа к очереди на основе содержимого списка управления доступом.Assigns access rights to the queue based on the contents of an access control list.

SetPermissions(MessageQueueAccessControlEntry)

Назначает права доступа к очереди на основе содержимого элемента управления доступом.Assigns access rights to the queue based on the contents of an access control entry.

SetPermissions(String, MessageQueueAccessRights)

Предоставляет компьютеру, группе или пользователю указанные права доступа.Gives a computer, group, or user the specified access rights.

SetPermissions(String, MessageQueueAccessRights, AccessControlEntryType)

Предоставляет компьютеру, группе или пользователю указанные права доступа указанного типа управления доступом (разрешить, отказать, отозвать или задать).Gives a computer, group, or user the specified access rights, with the specified access control type (allow, deny, revoke, or set).

ToString()

Возвращает объект String, содержащий имя Component, если оно есть.Returns a String containing the name of the Component, if any. Этот метод не следует переопределять.This method should not be overridden.

(Унаследовано от Component)

События

Disposed

Происходит при удалении компонента вызовом метода Dispose().Occurs when the component is disposed by a call to the Dispose() method.

(Унаследовано от Component)
PeekCompleted

Происходит, когда сообщение читается без удаления из очереди.Occurs when a message is read without being removed from the queue. Это результат асинхронной операции — BeginPeek().This is a result of the asynchronous operation, BeginPeek().

ReceiveCompleted

Происходит, если сообщение было удалено из очереди.Occurs when a message has been removed from the queue. Это событие инициируется асинхронной операцией, BeginReceive().This event is raised by the asynchronous operation, BeginReceive().

Методы расширения

Cast<TResult>(IEnumerable)

Приводит элементы объекта IEnumerable к заданному типу.Casts the elements of an IEnumerable to the specified type.

OfType<TResult>(IEnumerable)

Выполняет фильтрацию элементов объекта IEnumerable по заданному типу.Filters the elements of an IEnumerable based on a specified type.

AsParallel(IEnumerable)

Позволяет осуществлять параллельный запрос.Enables parallelization of a query.

AsQueryable(IEnumerable)

Преобразовывает коллекцию IEnumerable в объект IQueryable.Converts an IEnumerable to an IQueryable.

Применяется к

Потокобезопасность

Только метод GetAllMessages() является потокобезопасным.Only the GetAllMessages() method is thread safe.

Дополнительно