activeMQ tcp failoverの場合の接続障害の処理方法

Question

私はactiveMQ tcpフェールオーバー接続を使用してコンシューマを作成し、プロデューサによって生成されたトピックに加入しています。 どうすればネットワーク障害を管理できますか？ブローカとクライアント間の接続が切断されている場合、接続がいつ再確立されるのかをどのように知ることができますか？ また、プロデューサが稼動しているかどうかを知るにはどうすればよいですか？プロデューサを再起動する場合。どのように私はそれについて知っているので、私はトピックを再購読することができますか？あなたが再接続を管理する必要はありませんFailoverTransportと

Answer 1

、彼はプロデューサーの再起動場合は、トピックにmaxReconnectAttempts

再サブスクライブを指定しない限りindefinetly再接続しようとします??あなたの消費者は、彼がFailoverTransport状態の変更に通知する、必要がない場合でも、プロデューサー

の世話をするために持っていけない接続されているので必要ありません：

ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("failover:(tcp://host1:5670)"); 
    cf.setTransportListener(new TransportListener() { 
     @Override 
     public void transportResumed() { 
     } 

     @Override 
     public void transportInterupted() { 
     } 

     @Override 
     public void onException(IOException error) { 
     } 

     @Override 
     public void onCommand(Object command) { 
     } 
    });