ActiveMQ를 transportlistener 나는 두 개의 브로커를 사용하고

Question

를 사용 할이

ccf = new ActiveMQConnectionFactory(new URI("failover://(tcp://0.0.0.0:61617,tcp://0.0.0.0:61618)")); 
ccf.setTransportListener(this); 

한 브로커가 연결이 다운되면 다른 장애 에 다시 연결하는 것이 내가 로그에서 볼

하지만 어떻게 & 같은 소비자 연결을 작성하는 방법 내가

Answer 1

확인 transportlistener는 이제 ActiveMQConnection

cc = ccf.createConnection(); 
cc.start(); 
ActiveMQConnection acc = (ActiveMQConnection) cc; 
acc.addTransportListener(this); 

에 트랜스 설정해야이 이벤트를 잡을 portresumed 및 다른 콜백이 발생합니다.

Answer 2

이더넷 케이블이 연결되어 있지 않으면 transportInterrupted/Resumed가 호출되지 않습니다. 브로커에게 정상적인 종료가 수행 될 때 호출됩니다.