Transfert d'ActiveMQ d'un courtier local à un courtier distant [avec une connexion instable]

Question

J'ai le problème suivant: J'ai plusieurs sites avec un courtier ActiveMQ local qui transmet à un courtier distant (dans un centre de données). Cette connexion est souvent instable, et descend plusieurs fois par mois pendant quelques minutes ou quelques heures à la fois.

Les messages doivent donc attendre sur le courtier local si le courtier distant n'est pas accessible pour le moment.

J'ai la configuration ActiveMQ suivante:

<networkConnectors> 

      <networkConnector uri="static://(tcp://my-remote-broker:61616)" 
       name="myremotebroker" dynamicOnly="false" 
       conduitSubscriptions="true" 
       decreaseNetworkConsumerPriority="false"> 

        <!-- Exclude all destinations by default --> 

        <excludedDestinations> 
          <queue physicalName=">" /> 
          <topic physicalName=">" /> 
        </excludedDestinations> 

        <!-- Only forward these to our connection --> 

        <staticallyIncludedDestinations> 
          <topic physicalName="MySpecialTopic"/> 
        </staticallyIncludedDestinations> 
      </networkConnector> 
    </networkConnectors> 

Ce transmet les messages du courtier local (sur le sujet MySpecialTopic), au courtier à distance. Cela fonctionne lorsque la connexion est stable.

Cependant, j'ai essayé temporairement de désactiver la connexion Internet, de sorte que le courtier local a perdu la connexion avec le courtier distant. À ce moment, j'ai envoyé un nouveau message, qui a été mis en file d'attente sur le courtier local, mais n'est jamais arrivé sur le courtier distant, même après que le courtier local se soit reconnecté!

Y at-il quelque chose dans la configuration ActiveMQ qui me manque?

Merci!

Answer 1

Vous utilisez un TOPIC, qui est aléatoire. Cela signifie que l'envoi d'un message alors que la connexion est arrêtée sera perdu, ce qui est le comportement standard pour un sujet (seuls les abonnés qui sont abonnés au moment de l'envoi du message recevront le message). (http://activemq.apache.org/how-does-a-queue-compare-to-a-topic.html)

Vous devez utiliser une file d'attente si vous souhaitez que le consommateur distant reçoive le message OU configurer vos abonnés en tant qu'abonnés durables pour assurer qu'ils recevront des messages à tout moment. (http://activemq.apache.org/how-do-durable-queues-and-topics-work.html)