MessageEnumerator Kelas

Definisi

Ruang nama:

System.Messaging

Rakitan:

System.Messaging.dll

Menyediakan kursor terusan saja untuk menghitung pesan dalam antrean pesan.

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

Warisan

Object

MarshalByRefObject

MessageEnumerator

Penerapan

IEnumerator IDisposable

Contoh

Contoh berikut mendapatkan daftar pesan dinamis dalam antrean dan menghitung semua pesan dengan properti yang Priority diatur ke 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

Keterangan

Gunakan MessageEnumerator untuk interaksi dinamis dengan pesan dalam antrean. Metode yang tersedia melalui MessageQueue kelas dapat mengembalikan menunjuk MessageEnumerator ke daftar pesan dinamis dalam antrean, atau array yang berisi salinan pada instan tertentu - rekam jepret - dari antrean pada saat metode yang ditentukan dipanggil.

Tidak seperti rekam jepret statis, enumerator memungkinkan Anda untuk memodifikasi koleksi. MessageEnumeratorDengan menggunakan , Anda dapat menghapus pesan dari antrean, dan perubahan segera tercermin dalam antrean.

Enumerator tidak menghapus pesan dari antrean saat mengkueri antrean. Ini mengembalikan informasi tentang pesan pada posisi kursor saat ini, tetapi meninggalkan pesan dalam antrean.

MessageEnumerator adalah kursor, diinisialisasi ke kepala daftar dinamis. Urutan daftar sama dengan urutan pesan dalam antrean, sesuai dengan prioritas pesan. Anda dapat memindahkan kursor ke pesan pertama dalam antrean dengan memanggil MoveNext. Setelah enumerator diinisialisasi, Anda dapat menggunakan MoveNext untuk melangkah maju melalui pesan yang tersisa. Anda dapat menentukan apakah akan menunggu pesan tersedia dengan meneruskan batas waktu ke MoveNext dalam metode.

Karena enumerator bersifat dinamis, pesan yang ditambahkan di luar posisi kursor saat ini (misalnya, karena prioritas rendah), dapat diakses oleh enumerator. Pesan yang disisipkan sebelum posisi kursor saat ini tidak dapat diakses. Tidak dimungkinkan untuk mundur dengan MessageEnumerator. Kursor memungkinkan gerakan maju-saja. Metode ini Reset memungkinkan Anda menempatkan kursor kembali di awal antrean.

Instans untuk antrean MessageEnumerator tertentu bekerja secara independen. Anda dapat membuat dua MessageEnumerator instans yang berlaku untuk antrean yang sama. Perubahan yang MessageEnumerator dilakukan pada pesan dalam antrean akan segera tercermin dalam enumerator kedua jika enumerator kedua diposisikan sebelum yang pertama. Namun, jika dua enumerator memiliki posisi yang sama dan salah satunya menghapus pesan pada posisi tersebut, pengecualian akan dilemparkan jika enumerator lain mencoba mendapatkan nilai Current properti pada pesan yang sekarang dihapus.

Catatan

Jika Anda membuat instans MessageQueue dengan MessageQueue.DenySharedReceive diatur ke true, tidak ada aplikasi lain yang dapat mengubah pesan di enumerator Anda saat Anda memiliki koneksi ke antrean.

Properti

Current	Mendapatkan saat ini Message yang dirujuk oleh enumerator ini.
CursorHandle	Mendapatkan handel kursor Antrean Pesan asli yang digunakan untuk menelusuri pesan dalam antrean.

Metode

Close()	Membebaskan sumber daya yang terkait dengan enumerator.
CreateObjRef(Type)	Membuat objek yang berisi semua informasi relevan yang diperlukan untuk menghasilkan proksi yang digunakan untuk berkomunikasi dengan objek jarak jauh. (Diperoleh dari MarshalByRefObject)
Dispose()	Merilis semua sumber daya yang MessageEnumeratordigunakan oleh .
Dispose(Boolean)	Merilis sumber daya tidak terkelola yang MessageEnumerator digunakan oleh dan secara opsional merilis sumber daya terkelola.
Equals(Object)	Menentukan apakah objek yang ditentukan sama dengan objek saat ini. (Diperoleh dari Object)
GetHashCode()	Berfungsi sebagai fungsi hash default. (Diperoleh dari Object)
GetLifetimeService()	Mengambil objek layanan seumur hidup saat ini yang mengontrol kebijakan seumur hidup untuk instans ini. (Diperoleh dari MarshalByRefObject)
GetType()	Mendapatkan instans Type saat ini. (Diperoleh dari Object)
InitializeLifetimeService()	Mendapatkan objek layanan seumur hidup untuk mengontrol kebijakan seumur hidup untuk instans ini. (Diperoleh dari MarshalByRefObject)
MemberwiseClone()	Membuat salinan dangkal dari yang saat ini Object. (Diperoleh dari Object)
MemberwiseClone(Boolean)	Membuat salinan dangkal objek saat ini MarshalByRefObject . (Diperoleh dari MarshalByRefObject)
MoveNext()	Memajukan enumerator ke pesan berikutnya dalam antrean, jika saat ini tersedia.
MoveNext(TimeSpan)	Memajukan enumerator ke pesan berikutnya dalam antrean. Jika enumerator diposisikan di akhir antrean, MoveNext() tunggu hingga pesan tersedia atau batas waktu yang diberikan kedaluwarsa.
RemoveCurrent()	Menghapus pesan saat ini dari antrean transaksi atau non-transaksi dan mengembalikan pesan ke aplikasi panggilan. Tidak ada batas waktu yang ditentukan agar pesan tiba dalam antrean.
RemoveCurrent(MessageQueueTransaction)	Menghapus pesan saat ini dari antrean transaksi dan mengembalikan pesan ke aplikasi panggilan. Tidak ada batas waktu yang ditentukan agar pesan tiba dalam antrean.
RemoveCurrent(MessageQueueTransactionType)	Menghapus pesan saat ini dari antrean dan mengembalikan pesan ke aplikasi panggilan. Tidak ada batas waktu yang ditentukan agar pesan tiba dalam antrean.
RemoveCurrent(TimeSpan)	Menghapus pesan saat ini dari antrean dan mengembalikan pesan ke aplikasi panggilan. Jika ada pesan yang akan dihapus, metode akan segera mengembalikannya. Jika tidak, metode menunggu batas waktu yang ditentukan untuk pesan baru tiba.
RemoveCurrent(TimeSpan, MessageQueueTransaction)	Menghapus pesan saat ini dari antrean transaksi dan mengembalikan pesan ke aplikasi panggilan. Jika ada pesan yang akan dihapus, metode akan segera mengembalikannya. Jika tidak, metode menunggu batas waktu yang ditentukan untuk pesan baru tiba.
RemoveCurrent(TimeSpan, MessageQueueTransactionType)	Menghapus pesan saat ini dari antrean dan mengembalikan pesan ke aplikasi panggilan. Jika ada pesan yang akan dihapus, metode akan segera mengembalikannya. Jika tidak, metode menunggu batas waktu yang ditentukan untuk pesan baru tiba.
Reset()	Mengatur ulang enumerator saat ini sehingga menunjuk ke kepala antrean.
ToString()	Mengembalikan string yang mewakili objek saat ini. (Diperoleh dari Object)

Implementasi Antarmuka Eksplisit

IEnumerator.Current

Mengembalikan yang mereferensikan Message pesan pada posisi kursor saat ini.

Lihat juga

• Message
• GetMessageEnumerator2()