► Voir les détails de la configuration des resources JMS dans WebSphere Application Server dans la page : JMS (WebSphere Application Server).

• Créer un projet Maven:
  $ mvn archetype:generate \ -DarchetypeGroupId=org.apache.maven.archetypes \ -DarchetypeArtifactId=maven-archetype-webapp \ -DarchetypeVersion=1.4 \ -DgroupId=mtitek.modulez.mdb \ -DartifactId=mtitek-modulez-mdb \ -Dversion=1.0.0-SNAPSHOT \ -DinteractiveMode=false
  Importez le projet dans votre éditeur du code (Eclipse, NetBeans, …).
  
  Notes :
  Sur Linux, le caractère "\" permet d'écrire une commande sur plusieurs lignes.
  Sur Windows, il faut utiliser le caractère "^".
  
  
• Modifier le fichier "pom.xml":
  <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>mtitek.modulez.mdb</groupId> <artifactId>mtitek-modulez-mdb</artifactId> <version>1.0.0-SNAPSHOT</version> <packaging>war</packaging> <name>mtitek-modulez-mdb Maven Webapp</name> <dependencies> <dependency> <groupId>javax</groupId> <artifactId>javaee-api</artifactId> <version>6.0</version> <scope>provided</scope> </dependency> </dependencies> </project>
  
  
• Modifier le fichier "web.xml":
  <?xml version="1.0" encoding="ISO-8859-1"?> <web-app xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd" version="3.0"> <display-name>mtitek-modulez-mdb</display-name> </web-app>
  
  
• Créer une classe Java pour déclarer un MDB :
  package mtitek.modulez.mdb; import javax.ejb.ActivationConfigProperty; import javax.ejb.MessageDriven; import javax.jms.JMSException; import javax.jms.Message; import javax.jms.MessageListener; import javax.jms.TextMessage; @MessageDriven(mappedName = "jms/QTestA", activationConfig = { @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"), @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue") } ) public class MessageDrivenTestA implements MessageListener { public void onMessage(Message message) { System.out.println(this.getClass().toString() + " (" + this.toString() + ") - onMessage - Start"); System.out.println(message.toString()); try { if (message instanceof TextMessage) { TextMessage textMessage = (TextMessage) message; System.out.println(this.getClass().toString() + " (" + this.toString() + ") - onMessage (" + message.getClass().getName() + ") : " + textMessage.getText()); } else { System.out.println(this.getClass().toString() + " (" + this.toString() + ") - onMessage (" + message.getClass().getName() + ") : NOT SUPPORTED YET !!!"); } } catch (JMSException e) { throw new RuntimeException(e); } System.out.println(this.getClass().toString() + " (" + this.toString() + ") - onMessage - End"); } }
  
  
• Créer une Servlet (client) pour envoyer un message JMS au MDB (queue) :
  package mtitek.modulez.servlet; import java.io.IOException; import java.io.PrintWriter; import javax.annotation.Resource; import javax.jms.JMSException; import javax.jms.Queue; import javax.jms.QueueConnection; import javax.jms.QueueConnectionFactory; import javax.jms.QueueSender; import javax.jms.QueueSession; import javax.jms.Session; import javax.jms.TextMessage; import javax.servlet.ServletException; import javax.servlet.annotation.WebServlet; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; @WebServlet(urlPatterns = { "/MessageDrivenTestAServlet" }) public class MessageDrivenTestAServlet extends HttpServlet { private static final long serialVersionUID = 5076033838497882901L; @Resource(name = "rrnQCFTestA") private QueueConnectionFactory queueConnectionFactory; @Resource(name = "rrnQTestA") private Queue queue; private String sendTextMessage() { String sentTextMessageFlag = "SUCCESS ..."; QueueConnection queueConnection = null; QueueSession queueSession = null; try { queueConnection = queueConnectionFactory.createQueueConnection(); queueConnection.start(); queueSession = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); QueueSender queueSender = queueSession.createSender(queue); TextMessage textMessage = queueSession.createTextMessage(); textMessage.setText(this.getClass().toString() + " - JMS Hello, world! !"); queueSender.send(textMessage); } catch (JMSException e) { e.printStackTrace(); sentTextMessageFlag = "FAILURE ..."; } finally { try { if (queueSession != null) { queueSession.close(); } } catch (JMSException e) { e.printStackTrace(); } try { if (queueConnection != null) { queueConnection.close(); } } catch (JMSException e) { e.printStackTrace(); } } return sentTextMessageFlag; } @Override protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { response.setContentType("text/html; charset=utf-8"); PrintWriter out = response.getWriter(); out.println("<html>"); out.println("<head><title>MDB Hello, world! !</title></head>"); out.println("<body>"); out.println(this.getClass().toString() + " : MDB Hello, world! (1) !<hr /><br />"); out.println("<h1>" + sendTextMessage() + "</h1><br />"); out.println("</body>"); out.println("</html>"); out.flush(); out.close(); } }
  Notes :
  Si vous voulez utiliser JNDI au lieu de DI ("@Resource") pour injecter les ressources "ConnectionFactory" et "Queue", vous devriez ajouter la configuration de ces ressources dans le fichier "web.xml" :
  <resource-ref> <res-ref-name>rrnQCFTestA</res-ref-name> <res-type>javax.jms.QueueConnectionFactory</res-type> <res-auth>Container</res-auth> <res-sharing-scope>Shareable</res-sharing-scope> </resource-ref> <resource-ref> <res-ref-name>rrnQTestA</res-ref-name> <res-type>javax.jms.Queue</res-type> <res-auth>Container</res-auth> <res-sharing-scope>Shareable</res-sharing-scope> </resource-ref>
  Dans le code de la servlet vous devez ajouter un lookup JNDI de ces ressources comme suivant :
  Context ctx = new InitialContext(); QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory) ctx.lookup("java:comp/env/rrnQCFTestA"); Queue queue = (Queue) ctx.lookup("java:comp/env/rrnQTestA");
  
  
• Configurations supplémentaires relatives a WebSphere Application Server : Modifier le fichier "ibm-web-bnd.xml" (mtitek-modulez-mdb ► src ► main ► webapp ► WEB-INF ►):
  <?xml version="1.0" encoding="UTF-8"?> <web-bnd xmlns="http://websphere.ibm.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://websphere.ibm.com/xml/ns/javaee http://websphere.ibm.com/xml/ns/javaee/ibm-web-bnd_1_1.xsd" version="1.1"> <virtual-host name="default_host" /> <resource-ref name="rrnQCFTestA" binding-name="jms/QCFTestA" /> <resource-ref name="rrnQTestA" binding-name="jms/QTestA" /> </web-bnd>
  
  
• Configurations supplémentaires relatives a WebSphere Application Server : Modifier le fichier "ibm-ejb-jar-bnd.xml" (mtitek-modulez-mdb ► src ► main ► webapp ► WEB-INF ►):
  <?xml version="1.0" encoding="UTF-8"?> <ejb-jar-bnd xmlns="http://websphere.ibm.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://websphere.ibm.com/xml/ns/javaee http://websphere.ibm.com/xml/ns/javaee/ibm-ejb-jar-bnd_1_0.xsd" version="1.0"> <message-driven name="MessageDrivenTestA"> <jca-adapter activation-spec-binding-name="jms/ASTestA" activation-spec-auth-alias="" /> </message-driven> </ejb-jar-bnd>
  
  
• Créer, déployer et tester l'application :
  Pour builder le projet il faut utiliser la commande Maven : "mvn install".
  Le fichier WAR créé peut être déployé seul ou packagé dans un EAR.
  
  Pour tester l'intercepteur utiliser l'URL swivante : "http://localhost:9080/modulez-mdb/MessageDrivenTestAServlet"
  
  Voici un exemple de log du fichier "SystemOut.log" de WebSphere WAS :
  [26/12/14 11:34:18:496 EST] 00000071 SystemOut O class mtitek.modulez.mdb.MessageDrivenTestA (mtitek.modulez.mdb.MessageDrivenTestA@368c5bdb) - onMessage - Start [26/12/14 11:34:18:512 EST] 00000071 SystemOut O JMSMessage class: jms_text JMSType: null JMSDeliveryMode: 2 JMSExpiration: 0 JMSPriority: 4 JMSMessageID: ID:3224c7e9d5a72195e3b43a78110a134f0000000000000001 JMSTimestamp: 1419611658340 JMSCorrelationID: null JMSDestination: queue://QDTestA?busName=MyBus JMSReplyTo: null JMSRedelivered: false JMSXDeliveryCount: 1 JMSXAppID: Service Integration Bus JMS_IBM_System_MessageID: DF4A57008DFD32FE_14500001 JMSXUserID: class mtitek.modulez.servlet.MessageDrivenTestAServlet - JMS Hello, world! ! [26/12/14 11:34:18:512 EST] 00000071 SystemOut O class mtitek.modulez.mdb.MessageDrivenTestA (mtitek.modulez.mdb.MessageDrivenTestA@368c5bdb) - onMessage (com.ibm.ws.sib.api.jms.impl.JmsTextMessageImpl) : class mtitek.modulez.servlet.MessageDrivenTestAServlet - JMS Hello, world! ! [26/12/14 11:34:18:512 EST] 00000071 SystemOut O class mtitek.modulez.mdb.MessageDrivenTestA (mtitek.modulez.mdb.MessageDrivenTestA@368c5bdb) - onMessage - End
  

Dans certains cas, il est 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 ».

Voir un exemple pour afficher les message dans une queue en utilisant JBoss dans la page : Queue (JBoss)