MessageEnumerator 类

定义

public ref class MessageEnumerator : MarshalByRefObject, IDisposable, System::Collections::IEnumerator

public class MessageEnumerator : MarshalByRefObject, IDisposable, System.Collections.IEnumerator

type MessageEnumerator = class
    inherit MarshalByRefObject
    interface IEnumerator
    interface IDisposable

Public Class MessageEnumerator
Inherits MarshalByRefObject
Implements IDisposable, IEnumerator

继承

Object

MarshalByRefObject

MessageEnumerator

实现

IEnumerator IDisposable

示例

以下示例获取队列中消息的动态列表，并将 属性设置为 MessagePriority.Lowest的所有消息Priority计数。

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

using namespace System;
using namespace System::Messaging;
ref class MyNewQueue
{
public:
   void CountLowestPriority()
   {
      
      // Holds the count of Lowest priority messages.
      UInt32 numberItems = 0;
      
      // Connect to a queue.
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );
      
      // Get a cursor into the messages in the queue.
      MessageEnumerator^ myEnumerator = myQueue->GetMessageEnumerator();
      
      // Specify that the messages's priority should be read.
      myQueue->MessageReadPropertyFilter->Priority = true;
      
      // Move to the next message and examine its priority.
      while ( myEnumerator->MoveNext() )
      {
         
         // Increase the count if priority is Lowest.
         if ( myEnumerator->Current->Priority == MessagePriority::Lowest )
                  numberItems++;
      }

      
      // Display final count.
      Console::WriteLine( "Lowest priority messages: {0}", numberItems );
      return;
   }

};

int main()
{
   
   // Create a new instance of the class.
   MyNewQueue^ myNewQueue = gcnew MyNewQueue;
   
   // Output the count of Lowest priority messages.
   myNewQueue->CountLowestPriority();
   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 uses a cursor to step through the
        // messages in a queue and counts the number of
        // Lowest priority messages.
        //**************************************************

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

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

        //**************************************************
        // Iterates through messages in a queue and examines
        // their priority.
        //**************************************************
        
        public void CountLowestPriority()
        {
            // Holds the count of Lowest priority messages.
            uint numberItems = 0;

            // Connect to a queue.
            MessageQueue myQueue = new MessageQueue(".\\myQueue");
    
            // Get a cursor into the messages in the queue.
            MessageEnumerator myEnumerator =
                myQueue.GetMessageEnumerator();

            // Specify that the messages's priority should be read.
            myQueue.MessageReadPropertyFilter.Priority = true;

            // Move to the next message and examine its priority.
            while(myEnumerator.MoveNext())
            {
                // Increase the count if priority is Lowest.
                if(myEnumerator.Current.Priority ==
                    MessagePriority.Lowest)
                    
                    numberItems++;
            }

            // Display final count.
            Console.WriteLine("Lowest priority messages: " +
                numberItems.ToString());
            
            return;
        }
    }
}

Imports System.Messaging

Public Class MyNewQueue


        
        ' Provides an entry point into the application.
        '		 
        ' This example uses a cursor to step through the
        ' messages in a queue and counts the number of 
        ' Lowest priority messages.
        

        Public Shared Sub Main()

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

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

            Return

        End Sub


        
        ' Iterates through messages in a queue and examines
        ' their priority.
        

        Public Sub CountLowestPriority()

            ' Holds the count of Lowest priority messages.
            Dim numberItems As Int32 = 0

            ' Connect to a queue.
            Dim myQueue As New MessageQueue(".\myQueue")

            ' Get a cursor into the messages in the queue.
            Dim myEnumerator As MessageEnumerator = _
                myQueue.GetMessageEnumerator()

            ' Specify that the messages's priority should be read.
            myQueue.MessageReadPropertyFilter.Priority = True

            ' Move to the next message and examine its priority.
            While myEnumerator.MoveNext()

                ' Increase the count if the priority is Lowest.
                If myEnumerator.Current.Priority = _
                    MessagePriority.Lowest Then
                    numberItems += 1
                End If

            End While

            ' Display final count.
            Console.WriteLine(("Lowest priority messages: " + _
                numberItems.ToString()))

            Return

        End Sub

End Class

注解

用于 MessageEnumerator 与队列中的消息进行动态交互。 通过 MessageQueue 类提供的方法可以返回指向MessageEnumerator队列中消息的动态列表，也可以返回一个数组，该数组包含给定时刻的副本（调用指定方法时队列的快照）。

与静态快照不同，枚举器允许修改集合。 使用 ， MessageEnumerator可以从队列中删除消息，更改会立即反映在队列中。

枚举器在查询队列时不会从队列中删除消息。 它返回当前游标位置处的消息的相关信息，但会将消息保留在队列中。

是 MessageEnumerator 一个游标，初始化为动态列表的头。 根据消息优先级，列表顺序与队列中消息的顺序相同。 可以通过调用 MoveNext将光标移动到队列中的第一条消息。 初始化枚举器后，可以使用 MoveNext 向前单步执行剩余消息。 可以通过将超时 MoveNext 传递到 方法来指定是否等待消息变得可用。

由于枚举器是动态的，因此枚举器可以访问追加到游标当前位置之外的消息 (例如，由于低优先级) 。 在无法访问光标当前位置之前插入的消息。 不能使用 MessageEnumerator后退。 光标允许仅向前移动。 使用 Reset 方法可将游标放回队列的开头。

给定队列的 实例 MessageEnumerator 独立工作。 可以创建两 MessageEnumerator 个应用于同一队列的实例。 如果第二个 MessageEnumerator 枚举器位于第一个枚举器之前，则对队列中的消息所做的更改将立即反映在第二个枚举器中。 但是，如果两个枚举器具有相同的位置，并且其中一个枚举器删除位于该位置的消息，则当另一个枚举器尝试获取 Current 现在删除的消息上的 属性值时，将引发异常。

属性

方法

显式接口实现

适用于

另请参阅

• Message
• GetMessageEnumerator2()