2016-07-28 6 views

답변

0

당신은 어떤 아래와 같은 방법을 쓸 수

이 삭제 될 exchangeNames의 목록을 소요

채널 API를 사용할 수있는 방법 exchangeDelete 있습니다 :

삭제 익스체인지는

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); 

     } 
} 

그것을 모든 교환을 삭제합니다.

참고 : -> 난 RabbitMQ 서버에

+0

많은 감사를 연결 amqp-client.jar을 사용하고 있습니다. 귀하의 방법을 사용하고 모든 오류 항목이 제거되었습니다. 날 구해 줬어. 고맙습니다. – staticcast

관련 문제