RabbitMQ: Wie man den Austausch in einem Stapel löscht?

Question

Ich habe eine Menge Fehler Austausch (mit EasyNetQ), etwa 1400 Artikel erstellt. Der Name jedes Exchange sieht wie ErrorExchange_xxxxx aus.

Ich möchte sie alle löschen. Gibt es ein Skript, um die Austauschvorgänge in einem Stapel zu löschen?

Answer 1

Es gibt eine Methode exchangeDelete verfügbar mit Channel-API

Sie eine Methode schreiben können, wie zum Beispiel, unter der Liste der exchangeNames nimmt gelöscht werden:

DELETE EXCHANGE

public void deleteExcahnges(List<String> exchangeNames){} 
     ConnectionFactory factory = new ConnectionFactory(); 
     factory.setHost(localhost); 
     Connection connection = factory.newConnection(); 
     Channel channel = connection.createChannel(); 
     for(String exchangeName : exchangeNames){ 

     channel.exchangeDelete(exchangeName); 

     } 
} 

Es würde alle Austausche löschen.

Hinweis: -> Ich bin mit amqp-client.jar für