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

Ok TransportListener должен быть установлен на ActiveMQConnection

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

Теперь транс portresumed и другие обратные вызовы.

Answer 2

Транспортный прерывание/возобновление не вызывается, когда кабель Ethernet отсоединен. Он называется, когда грамотное завершение делается брокером.