MessageEnumerator Classe

Definição

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

Herança

Object

MarshalByRefObject

MessageEnumerator

Implementações

IEnumerator IDisposable

Exemplos

O exemplo a seguir obtém uma lista dinâmica de mensagens em uma fila e conta todas as mensagens com a Priority propriedade definida como 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

Comentários

Use MessageEnumerator para interação dinâmica com mensagens em uma fila. Os métodos disponíveis por meio da MessageQueue classe podem retornar um MessageEnumerator apontando para uma lista dinâmica de mensagens na fila ou uma matriz que contém uma cópia em um determinado instante - um instantâneo - da fila no momento em que o método especificado foi chamado.

Ao contrário de uma instantâneo estática, um enumerador permite modificar a coleção. Usando um MessageEnumerator, você pode remover mensagens da fila e a alteração é refletida imediatamente na fila.

Um enumerador não remove as mensagens da fila quando consulta a fila. Ele retorna informações sobre a mensagem na posição atual do cursor, mas deixa a mensagem na fila.

Um MessageEnumerator é um cursor, inicializado para o cabeçalho de uma lista dinâmica. A ordem de lista é a mesma que a ordem das mensagens na fila, de acordo com a prioridade da mensagem. Você pode mover o cursor para a primeira mensagem na fila chamando MoveNext. Depois que o enumerador for inicializado, você poderá usar MoveNext para avançar pelas mensagens restantes. Você pode especificar se deseja aguardar uma mensagem ficar disponível passando um tempo limite para o MoveNext método .

Como o enumerador é dinâmico, uma mensagem acrescentada além da posição atual do cursor (por exemplo, devido à baixa prioridade), pode ser acessada pelo enumerador. Uma mensagem que é inserida antes que a posição atual do cursor não possa ser acessada. Não é possível retroceder com um MessageEnumerator. Um cursor permite movimento somente encaminhamento. O Reset método permite que você coloque o cursor novamente no início da fila.

As instâncias de para MessageEnumerator uma determinada fila funcionam de forma independente. Você pode criar duas MessageEnumerator instâncias que se aplicam à mesma fila. As alterações feitas MessageEnumerator nas mensagens na fila serão refletidas imediatamente em um segundo enumerador se o segundo enumerador estiver posicionado antes do primeiro. No entanto, se dois enumeradores tiverem a mesma posição e um deles remover a mensagem nessa posição, uma exceção será gerada se o outro enumerador tentar obter o valor da Current propriedade na mensagem agora excluída.

Propriedades

Métodos

Implantações explícitas de interface

Aplica-se a

Confira também

• Message
• GetMessageEnumerator2()