我可以從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 
       { 
       } 
      } 
     } 
    }