我可以从c＃代码中的ActiveMQ队列中删除消息吗？

Question

我想为消息头中的每条消息设置一个唯一的guid，如果需要，我可以删除特定消息（如果需要）。 NMS中是否有任何API可以帮助我删除该消息？我正在使用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 
       { 
       } 
      } 
     } 
    }