20.6.6. Configurer un pontage JMS

HornetQ inclut un pontage de messages JMS qui fonctionne bien. La fonction de ce pontage est de comsommer des messages à partir d'un sujet ou d'une file d'attente source, et de les envoyer vers un sujet ou une file d'attente cible, se trouvant normalement sur un serveur différent.
Les serveurs sources et cibles ne doivent pas forcément être dans le même cluster, ce qui permet d'envoyer des messages d'un cluster à l'autre de façon fiable, via un WAN ou quand il y a une connexion fiable.
On peut déployer un pontage en tant qu'application autonome, avec le serveur autonome HornetQ ou à l'intérieur de l'instance JBoss AS. La source et la cible peuvent se trouver dans la même machine virtuelle ou dans une autre.

Exemple 20.4. Exemple de configuration de pontage JMS :

Les valeurs de cet exemples sont utilisées pour illustrer le reste de ce topic.
<subsystem>
  <subsystem xmlns="urn:jboss:domain:messaging:1.3">
             <hornetq-server>
             ...
             </hornetq-server>

             <jms-bridge name="myBridge">
                <source>
                    <connection-factory name="ConnectionFactory"/>
                    <destination name="jms/queue/InQueue"/>
                </source>
                <target>
                    <connection-factory name="jms/RemoteConnectionFactory"/>
                    <destination name="jms/queue/OutQueue"/>
                    <context>
                        <property key="java.naming.factory.initial" value="org.jboss.naming.remote.client.InitialContextFactory"/>
                        <property key="java.naming.provider.url" value="remote://192.168.40.1:4447"/>
                    </context>
                </target>
                <quality-of-service>AT_MOST_ONCE</quality-of-service>
                <failure-retry-interval>1000</failure-retry-interval>
                <max-retries>-1</max-retries>
                <max-batch-size>10</max-batch-size>
                <max-batch-time>100</max-batch-time>
                <add-messageID-in-header>true</add-messageID-in-header>
            </jms-bridge>
...
</subsystem>

Tableau 20.9. Attributs JMS d'HornetQ Core

Attribut Description
name
Tous les ponts doivent posséder un nom unique dans le serveur :
source connection-factory
Injecte le bean SourceCFF (comme défini dans le fichier de beans). Ce bean crée la ConnectionFactory source.
source destination name
Injecte le bean SourceDestinationFactory (comme défini dans le fichier de beans). Ce bean crée la Destination source.
target connection-factory
Injecte le bean TargetCFF (comme défini dans le fichier de beans). Ce bean crée la ConnectionFactory cible.
target destination name
Injecte le bean TargetDestinationFactory (comme défini dans le fichier de beans). Ce bean crée la Destination cible.
quality-of-service
Ce paramètre représente la qualité de mode de service requise. Les valeurs possibles sont : AT_MOST_ONCE, DUPLICATES_OK, ONCE_AND_ONLY_ONCE
failure-retry-interval
Représente la durée en millisecondes pendant laquelle il faut attendre pour créer à nouveau des connexions vers les serveurs source ou cible quand le pontage a détecté qu'ils ont échoué.
max-retries
Représente le nombre de tentatives pour créer à nouveau des connexions vers les serveurs source ou cible quand le pontage a détecté qu'ils ont échoué. Le pontage échouera après un certain nombre de tentatives. -1 représente un nombre d'éssais indéfini.
max-batch-size
Représente le nombre maximum de messages à consommer de la destination source avant de les envoyer en groupe vers une destination cible. Sa valeur doit >= 1.
max-batch-time
Cela représente la durée d'attente maximum en millisecondes avant d'envoyer un lot vers la cible, même si le nombre de messages consommés n'atteint pas la taille MaxBatchSize. Sa valeur doit être -1 pour correspondre à 'wait forever', ou bien >= 1 pour indiquer une durée précise.
add-messageID-in-header
Si défini sur true, alors l'id du message original sera ajouté dans le message envoyé à la destination dans l'en-tête HORNETQ_BRIDGE_MSG_ID_LIST. Si le message est envoyé plus d'une fois, chaque id de message sera ajouté. Cela permettra l'utilisation d'un modèle de requête-réponse distribué.
Quand vous recevrez le message, vous pourrez envoyer une réponse par l'id de corrélation de l'id du premier message, ce qui fait que quand l'émetteur d'origine recevra le message, il sera facile de faire une corrélation.
Pour obtenir des informations plus en détail, consultez  Section 20.9.2, « Créer un pontage JMS » .