Могу ли я удалить сообщение из очереди ActiveMQ в коде C#?

Question

Я хочу установить уникальное руководство для каждого сообщения в заголовке сообщения, а затем, если захочу, я могу удалить конкретное сообщение, если захочу. Есть ли api в NMS, который может помочь мне удалить сообщение? Я использую ActiveMQ 5.9.0 и NMS 1.6.1

Answer 1

Да, хотя только если у этого пункта назначения нет активных потребителей. Вы можете сделать что-то вроде этого:

protected static void DeleteDestination() 
    { 
     IConnectionFactory factory = new ConnectionFactory(ReplaceEnvVar(connectionURI)); 

     using (Connection connection = factory.CreateConnection() as Connection) 
     { 
      using (ISession session = connection.CreateSession()) 
      { 
       IQueue queue = session.GetQueue(testQueueName); 
       try 
       { 
        connection.DeleteDestination(queue); 
       } 
       catch 
       { 
       } 
      } 
     } 
    }