MessageQueue.Close Yöntem

Tanım

Ad Alanı:

System.Messaging

Bütünleştirilmiş Kod:

System.Messaging.dll

tarafından ayrılan tüm kaynakları boşaltıyor MessageQueue.

public:
 void Close();

public void Close();

member this.Close : unit -> unit

Public Sub Close ()

Örnekler

Aşağıdaki kod örneği bir Message Queuing kuyruğu kapatır.

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

using namespace System;
using namespace System::Messaging;
ref class MyNewQueue
{
public:

   // Sends a message to a queue.
   void SendMessage()
   {
      // Connect to a queue on the local computer.
      MessageQueue^ myQueue = gcnew MessageQueue( ".\\myQueue" );

      // Send a message to the queue.
      myQueue->Send( "My message data1." );

      // Explicitly release resources.
      myQueue->Close();

      // Attempt to reaquire resources.
      myQueue->Send( "My message data2." );
      return;
   }

   // Receives a message from a queue.
   void ReceiveMessage()
   {
      // Connect to the a 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 ] = String::typeid;
      myQueue->Formatter = gcnew XmlMessageFormatter( p );
      try
      {
         // Receive and format the message. 
         Message^ myMessage1 = myQueue->Receive();
         Message^ myMessage2 = myQueue->Receive();
      }
      catch ( MessageQueueException^ ) 
      {
         // Handle sources of any MessageQueueException.
      }
      finally
      {
         // Free resources.
         myQueue->Close();
      }

      return;
   }
};


// Provides an entry point into the application.
// This example closes a queue and frees its 
// resources.
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
{

    /// <summary>
    /// Provides a container class for the example.
    /// </summary>
    public class MyNewQueue
    {

        //**************************************************
        // Provides an entry point into the application.
        //	
        // This example closes a queue and frees its
        // resources.
        //**************************************************

        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 a message to a queue.
        //**************************************************
        
        public void SendMessage()
        {
            // Connect to a queue on the local computer.
            MessageQueue myQueue = new MessageQueue(".\\myQueue");

            // Send a message to the queue.
            myQueue.Send("My message data1.");
            
            // Explicitly release resources.
            myQueue.Close();

            // Attempt to reacquire resources.
            myQueue.Send("My message data2.");

            return;
        }

        //**************************************************
        // Receives a message from a queue.
        //**************************************************
        
        public  void ReceiveMessage()
        {
            // Connect to the a 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(String)});
            
            try
            {
                // Receive and format the message.
                Message myMessage1 = myQueue.Receive();
                Message myMessage2 = myQueue.Receive();
            }
            
            catch (MessageQueueException)
            {
                // Handle sources of any MessageQueueException.
            }

            // Catch other exceptions as necessary.

            finally
            {
                // Free resources.
                myQueue.Close();
            }

            return;
        }
    }
}

Imports System.Messaging

  
'Provides a container class for the example.

Public Class MyNewQueue



        ' Provides an entry point into the application.
        '	 
        ' This example closes a queue and frees its 
        ' resources.
 

        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 a message to a queue.
 

        Public Sub SendMessage()

            ' Connect to a queue on the local computer.
            Dim myQueue As New MessageQueue(".\myQueue")

            ' Send a message to the queue.
            myQueue.Send("My message data1.")

            ' Explicitly release resources.
            myQueue.Close()

            ' Attempt to reacquire resources.
            myQueue.Send("My message data2.")

            Return

        End Sub



        ' Receives a message from a queue.


        Public Sub ReceiveMessage()

            ' Connect to the a 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([String])})

            Try
                ' Receive and format the message. 
                Dim myMessage1 As Message = myQueue.Receive()
                Dim myMessage2 As Message = myQueue.Receive()

            Catch
                ' Handle sources of any MessageQueueException.

                ' Catch other exceptions as necessary.

            Finally

                ' Free resources.
                myQueue.Close()

            End Try

            Return

        End Sub

End Class

Açıklamalar

Close uygunsa paylaşılan kaynaklar da dahil olmak üzere bir MessageQueueile ilişkili tüm kaynakları serbesttir. Sistem, örneğin aşağıdaki C# kodunda olduğu gibi yöntemini çağırdığınızda Send(Object) bu kaynakları hala kullanılabilir durumdaysa otomatik olarak yeniden alır.

myMessageQueue.Send("Text 1.");
myMessageQueue.Close();
myMessageQueue.Send("Text 2."); //Resources are re-acquired.

çağrısı Closeyaptığınızda, Message Queuing kuyruğuna doğrudan erişen tüm MessageQueue özellikler temizlenir. Path, DefaultPropertiesToSend, Formatterve MessageReadPropertyFilter tümü olduğu gibi kalır.

Close , bir kuyruğa okuma ve yazma tanıtıcılarını her zaman serbest tutmaz, çünkü bunlar paylaşılabilir. Okuma ve yazma tanıtıcılarının kuyruğa serbest kalmasını sağlamak Close için aşağıdaki adımlardan herhangi birini uygulayabilirsiniz:

• MessageQueue özel erişimle oluşturun. Bunu yapmak için veya oluşturucuyu çağırın MessageQueue(String, Boolean) ve parametresini sharedModeDenyReceive olarak trueayarlayın.MessageQueue(String, Boolean, Boolean)

• MessageQueue Bağlantı önbelleğe alma devre dışı ile oluşturun. Bunu yapmak için oluşturucuyu çağırın MessageQueue(String, Boolean, Boolean) ve parametresini enableConnectionCache olarak falseayarlayın.

• Bağlantı önbelleğe almayı devre dışı bırakın. Bunu yapmak için özelliğini olarak falseayarlayınEnableConnectionCache.

Message Queuing sunucusundaki kuyruğu silmeden önce bir kuyruk çağırmalısınız Close . Aksi takdirde kuyruğa gönderilen iletiler özel durumlar atabilir veya teslim edilemeyen ileti kuyruğunda görünebilir.

Aşağıdaki tabloda, bu yöntemin çeşitli Çalışma Grubu modlarında kullanılabilir olup olmadığı gösterilmektedir.

Çalışma grubu modu	Mevcut
Yerel bilgisayar	Evet
Yerel bilgisayar ve doğrudan biçim adı	Evet
Uzak bilgisayar	Evet
Uzak bilgisayar ve doğrudan biçim adı	Evet