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

設置現在的反式恢復端口和其他回調發生。

Answer 2

以太網電纜拔出時不會調用transportInterrupted/Resumed。它在經紀人完成正常關機時調用。