我创建了很多错误交换(使用EasyNetQ),大约1400项。每个交易所的名称如下所示ErrorExchange_xxxxx
。
我要全部删除。是否有任何脚本可以批量删除交易所?
通道API提供了方法exchangeDelete
您可以编写如下所示的方法,该方法将要删除的exchangeNames列表:
删除交换
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);
}
}
它将删除所有交换。
注意:->我正在amqp-client.jar
用于连接到RabbitMQ服务器
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句