- Voir les détails de création d'un MDB (Queue) dans la page : Queue (EJB 3.1)

Modifier le fichier : "${JBOSS_HOME}/standalone/configuration/standalone.xml".
Ajouter la configuration suivante sous le sous-élément jms-destinations
<jms-destinations> <!-- La valeur de l'attribut "name" de l'élément "jms-queue" doit correspondre au nom de la queue pour les clients distants. --> <jms-queue name="queueTestAName"> <!-- La valeur l'attribut "name" de l'élément "entry" doit correspondre à la valeur de la propriété "destination" de l'annotation @ActivationConfigProperty de la MDB. --> <entry name="queue/testA"/> </jms-queue> </jms-destinations>
Notes :
- Si vous commencez avec JBoss, il sera peut-être plus facile de copier le contenu du fichier "standalone-full.xml" dans "standalone.xml".

Intra Virtual Machine (invm) : Ce type de connexion peut être utilisé lorsque le client HornetQ et le serveur HornetQ s'exécutent dans la même JVM.

Voir les détails d'utilisation d'un client local dans la page : Queue (EJB 3.1)

Ce type de connexion doit être utilisé lorsque le client HornetQ et le serveur HornetQ s'exécutent dans des JVM différentes (ce type de connecteur utilise le projet Netty pour gérer l'IO).
package com.mtitek.mdb.client; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.Session; import javax.jms.TextMessage; import org.hornetq.api.core.TransportConfiguration; import org.hornetq.api.jms.HornetQJMSClient; import org.hornetq.api.jms.JMSFactoryType; import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; public class MessageDrivenQueueARemoteClient { public static void main(String[] args) { Connection connection = null; Session session = null; try { TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName()); ConnectionFactory connectionFactory = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, transportConfiguration); // Le nom de la queue doit correspondre à la valeur de l'attribut "name" de l'élément "jms-queue" du fichier de configuration "standalone.xml" Queue queue = HornetQJMSClient.createQueue("queueTestAName"); connection = connectionFactory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(queue); TextMessage textMessage = session.createTextMessage(); textMessage.setText("Hello, world! (from remote client) !"); messageProducer.send(textMessage); } catch (JMSException e) { e.printStackTrace(); } finally { try { if (session != null) { session.close(); } } catch (JMSException e) { e.printStackTrace(); } try { if (connection != null) { connection.close(); } } catch (JMSException e) { e.printStackTrace(); } } } }
Voici la liste des jars à ajouter dans Eclipse pour que le code fonctionne :
- Click sur "Properties" ;
- Click sur "Java Build Path" ;
- Click sur "Libraries" ;
- Click sur "Add External Jars…" ;
- Ajouter les fichiers jar suivants :
${JBOSS_HOME}/modules/javax/jms/api/main/jboss-jms-api_1.1_spec-1.0.0.Final.jar ${JBOSS_HOME}/modules/org/hornetq/main/hornetq-core-2.2.13.Final.jar ${JBOSS_HOME}/modules/org/hornetq/main/hornetq-jms-2.2.13.Final.jar ${JBOSS_HOME}/modules/org/jboss/netty/main/netty-3.2.6.Final.jar
Vous devez aussi autoriser les utilisateurs « guest » à envoyer des messages à distance :

• Dans le fichier "standalone.xml" (${JBOSS_HOME}/standalone/configuration/), ajouter l'élément <module-option name="unauthenticatedIdentity" value="guest" /> :
  <subsystem xmlns="urn:jboss:domain:security:1.1"> <security-domains> <security-domain name="other" cache-type="default"> <authentication> <login-module code="Remoting" flag="optional"> <module-option name="password-stacking" value="useFirstPass"/> </login-module> <login-module code="RealmUsersRoles" flag="required"> <module-option name="usersProperties" value="${jboss.server.config.dir}/application-users.properties"/> <module-option name="rolesProperties" value="${jboss.server.config.dir}/application-roles.properties"/> <module-option name="realm" value="ApplicationRealm"/> <module-option name="password-stacking" value="useFirstPass"/> <module-option name="unauthenticatedIdentity" value="guest"/> </login-module> </authentication> </security-domain> <security-domain name="jboss-web-policy" cache-type="default"> <authorization> <policy-module code="Delegating" flag="required"/> </authorization> </security-domain> <security-domain name="jboss-ejb-policy" cache-type="default"> <authorization> <policy-module code="Delegating" flag="required"/> </authorization> </security-domain> </security-domains> </subsystem>
  
  
• Vous devez aussi activer le rôle « guest » dans le fichier "application-roles.properties" (${JBOSS_HOME}/standalone/configuration/) :
  guest=guest
  
  

Notes :
- Ces configurations suppose que vous avez pris le contenu du fichier "standalone-full.xml", sinon vous devriez ajouter d'autres configuration manuellement pour que le code fonctionne.

Dans certains cas, il sera utile de naviguer dans la queue et vérifier les messages qui sont dans la queue (éventuellement ces messages ne sont pas encore traités ou il n'y a pas de MDBs correspondants pour la queue destinataire de ces messages).

Exemple, si un message est envoyé avec un messageSelector qui n'est pas précisé par aucun MDB, alors le message va rester dans la queue.

Notes :
- Voir plus des détails sur l'utilisation de la propriété « messageSelector » dans la page : Propriété « messageSelector » (EJB 3.1).
package com.mtitek.mdb.client; import java.util.Enumeration; import javax.jms.Connection; import javax.jms.ConnectionFactory; import javax.jms.JMSException; import javax.jms.MessageProducer; import javax.jms.Queue; import javax.jms.QueueBrowser; import javax.jms.Session; import javax.jms.TextMessage; import org.hornetq.api.core.TransportConfiguration; import org.hornetq.api.jms.HornetQJMSClient; import org.hornetq.api.jms.JMSFactoryType; import org.hornetq.core.remoting.impl.netty.NettyConnectorFactory; import org.hornetq.jms.client.HornetQTextMessage; public class MessageDrivenQueueABrowser { public static void main(String[] args) { Connection connection = null; Session session = null; try { TransportConfiguration transportConfiguration = new TransportConfiguration(NettyConnectorFactory.class.getName()); ConnectionFactory connectionFactory = (ConnectionFactory) HornetQJMSClient.createConnectionFactoryWithoutHA(JMSFactoryType.CF, transportConfiguration); // Le nom de la queue doit correspondre à la valeur de l'attribut "name" de l'élément "jms-queue" du fichier de configuration "standalone.xml" Queue queue = HornetQJMSClient.createQueue("queueTestAName"); connection = connectionFactory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // Créer un message qui ne sera consumé par aucun MDB MessageProducer messageProducer = session.createProducer(queue); TextMessage textMessage = session.createTextMessage(); textMessage.setStringProperty("messageOrder", "UNKNOWN"); textMessage.setText("Hello, world! - Unknown message (from remote client) !!!"); messageProducer.send(textMessage); // Naviguer dans la queue pour vérifier s'il y a des messages non traités QueueBrowser queueBrowser = session.createBrowser(queue); Enumeration<?> enumeration = queueBrowser.getEnumeration(); System.out.println("Messages non traités dans la queue :"); while (enumeration.hasMoreElements()) { Object object = (Object) enumeration.nextElement(); if (object instanceof HornetQTextMessage) { HornetQTextMessage hornetQTextMessage = (HornetQTextMessage) object; System.out.println(hornetQTextMessage.getText()); } else { System.out.println(object.toString()); } } } catch (JMSException e) { e.printStackTrace(); } finally { try { if (session != null) { session.close(); } } catch (JMSException e) { e.printStackTrace(); } try { if (connection != null) { connection.close(); } } catch (JMSException e) { e.printStackTrace(); } } } }
Voici la sortie dans la console Eclipse :
Messages non traités dans la queue : Hello, world! - Unknown message (from remote client) !!!