Red Hat Training

A Red Hat training course is available for Red Hat JBoss Enterprise Application Platform

18.8.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 18.4. Exemple de configuration de pontage JMS :

Les valeurs de cet exemple sont utilisées pour illustrer le reste de cette section. 
<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 18.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 d'origine.
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 qu'il faut attendre pour créer à nouveau des connexions vers les serveurs sources ou cibles 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 sources ou cibles 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 être >= 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.

Note

Quand on ferme un serveur qui a un pont JMS déployé avec un attribut quality-of-service défini à ONCE_AND_ONLY_ONCE, commencer par fermer le serveur avec le pont JMS pour éviter les exceptions inattendues.
Pour obtenir des informations plus en détail, consultez  Section 18.11.2, « Créer un pontage JMS » .
Rapporter un bogue