Red Hat Summit18.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>
| 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 » .
