- Voir les détails de création d'une MDB (Topic) dans la page : Topic (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-topic" doit correspondre au nom du topic pour les clients distants. --> <jms-topic name="topicTestAName"> <!-- 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="topic/testA"/> </jms-topic> </jms-destinations>

invm (Intra Virtual Machine) : 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 : Topic (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.Session; import javax.jms.TextMessage; import javax.jms.Topic; 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 MessageDrivenTopicARemoteClient { 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 du topic doit correspondre à la valeur de l'attribut "name" de l'élément "jms-topic" du fichier de configuration "standalone.xml" Topic topic = HornetQJMSClient.createTopic("topicTestAName"); connection = connectionFactory.createConnection(); connection.start(); session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); MessageProducer messageProducer = session.createProducer(topic); 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(); } } } }