NMS.ActiveMQ 目的地管理
Apache.NMS.ActiveMQ 客戶端除了標準的 NMS API 之外,還提供了一些額外功能。其中一個功能是能夠刪除 Broker 上的指定目的地。這在測試時,當您想以已知狀態(空或非空)啟動測試目的地時非常有用。您可以刪除目的地,然後下一次發送到該目的地的操作將在 Broker 端重新建立它。刪除目的地就像以下程式碼一樣簡單:
刪除目的地
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
{
}
}
}
}