MessageEnumerator Klass

Definition

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

Arv

Object

MarshalByRefObject

MessageEnumerator

Implementeringar

IEnumerator IDisposable

Exempel

I följande exempel hämtas en dynamisk lista med meddelanden i en kö och alla meddelanden räknas med egenskapen Priority inställd på MessagePriority.Lowest.

#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

Kommentarer

Används MessageEnumerator för dynamisk interaktion med meddelanden i en kö. Metoder som är tillgängliga via MessageQueue klassen kan returnera antingen en MessageEnumerator pekar på en dynamisk lista med meddelanden i kön eller en matris som innehåller en kopia vid ett givet ögonblick – en ögonblicksbild – av kön vid den tidpunkt då den angivna metoden anropades.

Till skillnad från en statisk ögonblicksbild kan du ändra samlingen med en uppräknare. Med hjälp av kan MessageEnumeratordu ta bort meddelanden från kön och ändringen återspeglas omedelbart i kön.

En uppräknare tar inte bort meddelandena från kön när den frågar kön. Den returnerar information om meddelandet vid den aktuella markörens position, men det lämnar meddelandet i kön.

A MessageEnumerator är en markör som initieras till huvudet på en dynamisk lista. Listordningen är samma som ordningen på meddelandena i kön, enligt meddelandeprioritet. Du kan flytta markören till det första meddelandet i kön genom att anropa MoveNext. När uppräknaren har initierats kan du använda MoveNext för att gå vidare genom de återstående meddelandena. Du kan ange om du vill vänta tills ett meddelande blir tillgängligt genom att skicka en timeout till MoveNext metoden.

Eftersom uppräknaren är dynamisk kan ett meddelande som läggs till utanför markörens aktuella position (till exempel på grund av låg prioritet) nås av uppräknaren. Det går inte att komma åt ett meddelande som infogas före markörens aktuella position. Det går inte att gå bakåt med en MessageEnumerator. En markör tillåter framåtriktad rörelse. Med Reset metoden kan du placera markören i början av kön.

Instanser av för en viss kö fungerar oberoende av MessageEnumerator varandra. Du kan skapa två MessageEnumerator instanser som gäller för samma kö. De ändringar som görs MessageEnumerator i meddelandena i kön återspeglas omedelbart i en andra uppräknare om den andra uppräknaren placeras före den första. Men om två uppräknare har samma position och en av dem tar bort meddelandet vid den positionen utlöses ett undantag om den andra uppräknaren försöker hämta värdet Current för egenskapen i det nu borttagna meddelandet.

Se även

• Message
• GetMessageEnumerator2()