activemq 传输监听器如何使用答案

【问题标题】：activemq transportlistener how to useactivemq 传输监听器如何使用
【发布时间】：2012-12-16 09:43:33
【问题描述】：

我正在使用两个代理并像这样创建消费者连接

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

我在日志中看到，如果一个代理出现故障，连接会重新连接到另一个故障转移但是我如何以及在哪里捕捉这个事件

【问题讨论】：

标签： activemq

【解决方案1】：

好的transportlistener需要在ActiveMQConnection上设置

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

现在传输恢复和其他回调发生。

【讨论】：

【解决方案2】：

拔下以太网电缆时不会调用 transportInterrupted/Resumed。当代理正常关闭时调用它..

【讨论】：