Uploaded image for project: 'Qpid'
  1. Qpid
  2. QPID-8673

Qpid Broker Not Auto Delete Exchange Created Corresponding Queue

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • qpid-cpp-1.39.0
    • None
    • C++ Broker
    • None
    • Centos7.9 C++ Broker 1.39.0
      window 11 dotnet proton 1.0.0-M9

    Description

      we using Proton(DotNet) api create Receiver connect to C++ Broker,

      After close connection, C++ Broker did not delete  queue which auto created by Exchange Address.

       

      Steps to reproduce:

      C++ Broker create test exchange first, command:
      qpid-config -b localhost:6656 add exchange topic ryan_test3_ex --durable

      qpid-config -b localhost:6656 exchanges

      show follow exchagnes

      Type      Exchange Name       Attributes
      ==================================================
      direct                        --replicate=none
      direct    amq.direct          --durable --replicate=none
      fanout    amq.fanout          --durable --replicate=none
      headers   amq.match           --durable --replicate=none
      topic     amq.topic           --durable --replicate=none
      direct    qmf.default.direct  --replicate=none
      topic     qmf.default.topic   --replicate=none
      topic     qpid.management     --replicate=none
      topic     ryan_test3_ex       --durable

      1) centos: qpid-config -b localhost:6656 queues

      Show following:

      Queue Name                                                                                            Attributes
      =============================================================================================================================
      038154c3-daf7-4fad-ad45-4eef738bccba:0.0                                                              auto-del excl 
      ID:02eafb79-b51e-4fef-b242-f86d453debb1:1:1_receiver-ID:02eafb79-b51e-4fef-b242-f86d453debb1:1:1:1:1  
      ID:f78b1699-d494-4f43-8413-d1e7e00e20fa:1:1_receiver-ID:f78b1699-d494-4f43-8413-d1e7e00e20fa:1:1:1:1  excl  

      2) run window dotnet receive to receive message,C# code snippet 

      private static readonly int MessageCount = 5;

      static void Main(string[] args)
      {
          string serverHost = Environment.GetEnvironmentVariable("HOST") ?? "192.168.1.34";
          int serverPort = Convert.ToInt32(Environment.GetEnvironmentVariable("PORT") ?? "6656");
          string address = Environment.GetEnvironmentVariable("ADDRESS") ?? "ryan_test3_ex";

          IClient client = IClient.Create();
          ConnectionOptions options = new ConnectionOptions();
          //options.User = Environment.GetEnvironmentVariable("USER");
          //options.Password = Environment.GetEnvironmentVariable("PASSWORD");
          using IConnection connection = client.Connect(serverHost, serverPort, options);
          using IReceiver receiver = connection.OpenReceiver(address);

          for (int i = 0; i < MessageCount; ++i)
          {
              IDelivery delivery = receiver.Receive();
              IMessage<object> received = delivery.Message();
              string contenttype = received.ContentType;
              if (string.IsNullOrEmpty(contenttype))
              {
                  if (received.HasProperty("content-type"))
                 

      {                 contenttype = received.GetProperty("content-type") as string;                 Console.WriteLine("Received message with content-type: " + contenttype);             }

              }
              Console.WriteLine("Received message tpye:[" + contenttype + "] BodyType:[" +  received.Body.GetType() + "]");
              if(contenttype == "amqp/map")
              {
                  Dictionary<object, object> content = received.Body as Dictionary<object, object>;
                  if (content != null)
                  {
                      foreach (KeyValuePair<object, object> entry in content)
                     

      {                     Console.WriteLine("   Key: " + entry.Key as string + ", Value: " + entry.Value as string);                     //Console.WriteLine("   Key: " + (entry.Key as string) + ", Value: " + (Int64)entry.Value);                 }

                  }
              }
              else if (contenttype == "text/plain")
             

      {             Console.WriteLine("    Received Message : " + Encoding.UTF8.GetString(received.Body as Byte[]));         }

              else
             

      {         }

          }

          connection.Close();
          Console.WriteLine("    Connection close OK !!");

       

      dotnet proton test code has attached.

       

      3) using test tool spout send 5 messages.

      spout --b localhost:6656 ryan_test3_ex -P MsgType="2" -S aa.34 -M UserID=111111 -M InvestorID=18080095 -c 5

       

      4) DotNet Proton receiver got 5 message and exist successful.

      5)Centos run: qpid-config -b localhost:6656 queues

      qpid-config -b localhost:6656 queues
      Queue Name                                                                                            Attributes
      =============================================================================================================================
      038154c3-daf7-4fad-ad45-4eef738bccba:0.0                                                              auto-del excl 
      ID:02eafb79-b51e-4fef-b242-f86d453debb1:1:1_receiver-ID:02eafb79-b51e-4fef-b242-f86d453debb1:1:1:1:1  
      ID:f78b1699-d494-4f43-8413-d1e7e00e20fa:1:1_receiver-ID:f78b1699-d494-4f43-8413-d1e7e00e20fa:1:1:1:1  excl  
      ID:ff934946-f75f-49e2-bef6-ecd56fc9c979:1:1_receiver-ID:ff934946-f75f-49e2-bef6-ecd56fc9c979:1:1:1:1 

       

      queue:

      ID:ff934946-f75f-49e2-bef6-ecd56fc9c979:1:1_receiver-ID:ff934946-f75f-49e2-bef6-ecd56fc9c979:1:1:1:1   would not auto delete

       

      we using qpid tool:
      spout send message, drain receive message, is ok.

       

      we also reported a issue for proton:

      https://issues.apache.org/jira/browse/PROTON-2833

       

      Attachments

        1. Program.cs
          3 kB
          ryanwei
        2. ConsoleApp2.csproj
          0.5 kB
          ryanwei

        Activity

          People

            Unassigned Unassigned
            wei6rong ryanwei
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: