ブローカのネットワークをコンフィグレーションするキューコンシューマをローカルホストにしないブローカのエラーが発生しない限り

Question

私はブローカのペアをActiveMQ 5.5.1のブローカのネットワークとして設定しています。各ブローカーは、WANを介して通信するサーバー上に存在します。

<amq:queue id="myQueue" physicalName="myQueue" /> 
<amq:topic id="myTopic" physicalName="MyTopic" /> 

：

<amq:broker useJmx="false" persistent="false"> 
    <amq:networkConnectors> 
     <amq:networkConnector uri="static:(tcp://BrokerB:61616)" duplex="true" /> 
    </amq:networkConnectors> 
    <amq:transportConnectors> 
     <amq:transportConnector uri="tcp://BrokerA:61616" /> 
    </amq:transportConnectors> 
</amq:broker> 

BrokerB各サーバーでサーバーB

<amq:broker useJmx="false" persistent="false"> 
    <amq:networkConnectors> 
     <amq:networkConnector uri="static:(tcp://BrokerA:61616)" duplex="true" /> 
    </amq:networkConnectors> 
    <amq:transportConnectors> 
     <amq:transportConnector uri="tcp://BrokerB:61616" /> 
    </amq:transportConnectors> 
</amq:broker> 

上のサーバーA上の

BrokerA、私は次のトピックとキューを作成するJavaサービスが実行されています

javaサービス（各サーバー上）は、myQueueのプロデューサとコンシューマ、およびmyTopicのプロデューサとコンシューマを作成します。両方の消費者がmyTopicにすべてのトピックメッセージを受け取るようにしてください。問題はmyQueueです。構成されたブローカーがmyQueueメッセージを消費するだけです。たとえば、BrokerAがServerAでサービスメッセージを生成する場合、私はServerB上のBrokerBがそのメッセージを消費するようにしたいだけです。私のテストでは、ServerAで生成されたメッセージの約50％がBrokerAで消費され、50％がBrokerBで消費されています。さらに、BrokerBがオフラインになった場合、BrokerBはオンラインでmyQueueメッセージを受け入れ、すべてmyQueueメッセージを消費して、BrokerBがオンラインに戻るまでメッセージを消費する必要があります。

私はメッセージグループの使用について考えていましたが、メッセージが送信されたグループを切り替えるために障害が発生したときに検出するための良い方法を考え出すことができませんでした。どんな勧告も大いにありがとう！

Answer 1

あなたは、消費者が「ブローカー失敗しない限り、地元のブローカーに接続したことがない」ことを確認することについて、あなたの他の質問に

<networkConnectors> 
    <networkConnector uri="static:(tcp://BrokerB:61616)" duplex="true" > 
     <excludedDestinations> 
      <queue physicalName="myQueue"/> 
     </excludedDestinations> 
    </networkConnector> 
</networkConnectors> 

...他のブローカーに行くからキューのメッセージを防止するための「excludedDestinations」を指定することができます。あなたのクライアント接続で次の操作を行い..if、あなたはいつも私は、その利用できない...また、リモートブローカに回復するだろう、それが利用可能になる

failover:(tcp://remoteBroker,tcp://localBroker)?randomize=false&priorityBackup=true