CodeS-SourceS
Rechercher un code, un tuto, une réponse

Les EJBs JMS

Août 2017


Les EJBs JMS


Ce tutorial donne un exemple d'implémentation des EBJs JMS



Introduction


Les Message-driven Beans fournissent des modes d'accès asynchrones comme spéfié dans les spécifications EJB 2.0.
De plus, il est possible pour tout les EJB ( session, entity, ou Message-driven ) d'envoyer ou recevoir de façon synchrone des messages. Pour cela en plus de l'implémentation, il faut penser paramétrer ses Queues et Factory sur le serveur d'application ( ici : Weblogic 8.1) .

Contenu de ejb-jar.xml


<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE ejb-jar PUBLIC "-//Sun Microsystems, Inc.//DTD Enterprise JavaBeans 2.0//EN" "http://java.sun.com/dtd/ejb-jar_2_0.dtd">
<ejb-jar>
 <display-name>Clint EJB</display-name>
 <enterprise-beans>
  <message-driven>
   <display-name>AlerteMessageBean</display-name>
   <ejb-name>AlerteMessageBean</ejb-name>
   <ejb-class>fr.zieunoir.ejb.AlerteMessageBean</ejb-class>
   <transaction-type>Container</transaction-type>
   <message-driven-destination>
    <destination-type>javax.jms.Queue</destination-type> 
   </message-driven-destination>
  </message-driven>
 </enterprise-beans>
 <assembly-descriptor>
  <container-transaction>
            <method>
                <description />
                <ejb-name>AlerteMessageBean</ejb-name>
                <method-name>*</method-name>
            </method>
            <trans-attribute>NotSupported</trans-attribute>
        </container-transaction>
 </assembly-descriptor>
</ejb-jar>

Contenu de weblogic-ejb-jar.xml


<weblogic-enterprise-bean>
 <ejb-name>AlerteMessageBean</ejb-name>
 <message-driven-descriptor>
  <pool>
   <max-beans-in-free-pool>5</max-beans-in-free-pool>
   <initial-beans-in-free-pool>5</initial-beans-in-free-pool>
  </pool>
  <destination-jndi-name>AlerteInfoQueue</destination-jndi-name>
  <connection-factory-jndi-name>AlerteInfoFactory</connection-factory-jndi-name>
 </message-driven-descriptor>
</weblogic-enterprise-bean>

MessageManager


La classe MessageManager s'occupe de l'envoi des messages.

package fr.zieunoir.ejb;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import java.util.Properties;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;


/**
 *Titre : 
 *Description : 
 *Copyright : Copyright (c) 2003
 *Soci? : 
 *@author non attribuable
 *@version 1.0
 */	
public final class MessageManager {
    protected Static Log log = LogFactory.getLog(
            "fr.zieunoir.ejb.MessageManager");

    /**services */
    private Static String alerteQueue = null;
    private Static String alerteFactory = null;
    private Static MessageManager instance = null;
    private QueueConnectionFactory fatyinst = null;

    /**
     *Constructeur privé    */	
    private MessageManager() {
        alerteQueue = "AlerteInfoQueue";
        alerteFactory = "AlerteInfoFactory";
    }

    /**
     *Retourne l'instance unique du Manager
     *@return
     */	
    public Static synchronized MessageManager getInstance() {
        if (instance == null) {
            instance = new MessageManager();
        }

        return instance;
    }

    /**
      *Envoi un message avec des paramêtres
      *@param typeAlerteAEnvoyer = sur/sous conso, depassement, energie reactive
      */	
    public void sendMessage(String typeAlerteAEnvoyer) {
        QueueConnection cnx = null;
        QueueSession session = null;
        QueueSender sender = null;
        Queue queue = null;
        Message message = null;

        cnx = getConnexion();

        if (cnx != null) {
            try {
                session = getSession(cnx);
                queue = getQueue();
                sender = session.createSender(queue);
                message = session.createMessage();
                message.setStringProperty("TYPE_ALERTE", typeAlerteAEnvoyer);
                sender.send(message);
            } catch (JMSException ex) {
                log.error(ex);
            } finally {
                try {
                    if (sender != null) {
                        sender.close();
                    }

                    if (session != null) {
                        session.close();
                    }

                    if (cnx != null) {
                        cnx.close();
                    }
                } catch (JMSException ex) {
                    log.error(ex);
                }
            }
        }
    }

    /**
     *retrouve un Factory pour l'instance
     *@return QueueConnectionFactory 
     */
    private QueueConnectionFactory getFactory() {
        QueueConnectionFactory factory = null;
        Properties env = new Properties();
        env.put(Context.INITIAL_CONTEXT_FACTORY,
            "weblogic.jndi.WLInitialContextFactory");
        env.put(Context.PROVIDER_URL, "t3://localhost:7001");

        try {
            Context ctx = new InitialContext(env);
            factory = (QueueConnectionFactory) ctx.lookup(alerteFactory);
        } catch (NamingException ex) {
            log.error(ex);
        }

        return factory;
    }

    /**
     *Récupération de la connexion
     *@return QueueConnection 
     */	
    private QueueConnection getConnexion() {
        QueueConnection cnx = null;

        if (fatyinst == null) {
            fatyinst = getFactory();
        }

        if (fatyinst != null) {
            try {
                cnx = fatyinst.createQueueConnection();

                //cnx = fatyinst.();
            } catch (JMSException ex) {
                log.error(ex);
            }
        }

        return cnx;
    }

    /**
     *Récupération d'une session
     *@return QueueSession 
     */
    private QueueSession getSession(QueueConnection pcnx) {
        QueueSession session = null;

        if (pcnx != null) {
            try {
                session = pcnx.createQueueSession(false,
                        QueueSession.AUTO_ACKNOWLEDGE);
            } catch (JMSException ex) {
                log.error(ex);
            }
        }

        return session;
    }

    /**
     *Récuréation d'une queue dans l'annuaire
     *@return Queue
     */	
    private Queue getQueue() {
        Queue queue = null;
        Properties env = new Properties();

        env.put(Context.INITIAL_CONTEXT_FACTORY,
            "weblogic.jndi.WLInitialContextFactory");
        env.put(Context.PROVIDER_URL, "t3://localhost:7001");

        try {
            Context ctx = new InitialContext(env);
            queue = (Queue) ctx.lookup(alerteQueue);
        } catch (NamingException ex) {
            log.error(ex);
        }

        return queue;
    }
}

La classe JMS qui fait le traitement des messages


package fr.zieunoir.ejb;

import fr.zieunoir.dao.valerte.ValerteBean;
import fr.zieunoir.dao.valerte.ValerteManager;
import fr.zieunoir.service.ServiceLocatorException;

import org.apache.log4j.Logger;

import weblogic.ejb.GenericMessageDrivenBean;

import java.sql.SQLException;

import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;


//to be done creer une queue jms et la configurer

/**
 *@ejbgen:message-driven
 *  ejb-name = AlerteMessageBean
 *  destination-jndi-name = jms.DepecheJMSDestination
 *  destination-type = javax.jms.Queue
 *
 *@ejbgen:ejb-ref type="Session"        remote="DataManipSession"
 *    home="DataManipSessionHome"
 *    jndi-name="ejb.DataManipSessionRemoteHome"
 *    name="DataManipSession"
 *
 */	
public class AlerteMessageBean extends GenericMessageDrivenBean
    implements MessageDrivenBean, MessageListener {


    private Static final long serialVersionUID = 1L;
    private transient Logger log = Logger.getLogger(AlerteMessageBean.class);
    private MessageDrivenContext messageDrivenContext = null;

    /**
     *Mode appell??a r?ption d'un message JMS,
     *d?enche la mise ?our du canal de d?che spacifi?ans le message JMS
     *@param Message le message JMS re?
     */
    public void onMessage(Message msg) {
        ValerteManager man = null;

        try {
            man = ValerteManager.getInstance();
        } catch (ServiceLocatorException e1) {
            // TODO Auto-generated catch block
            e1.printStackTrace();
        }

        ValerteBean[] listeUser = null;
        String sujetMail = null;
        String urlJsp = null;

        try {
            final String typeAlerteAEnvoyer = msg.getStringProperty(
                    "TYPE_ALERTE");

            if ("1".equals(typeAlerteAEnvoyer)) {
                listeUser = man.loadDetailAlerte1();
                sujetMail = "ZieunoirJMS : ";
                urlJsp = "/jsp/externe/mail_mailAlerte.jsp";
            } else if ("2".equals(typeAlerteAEnvoyer)) {
                listeUser = man.loadDetailAlerte2();
                sujetMail = "ZieunoirJMS : ";
                urlJsp = "/jsp/externe/mail_mailPenalite.jsp";
            } else if ("3".equals(typeAlerteAEnvoyer)) {
                listeUser = man.loadDetailAlerte3();
                sujetMail = "ZieunoirJMS : ";
                urlJsp = "/jsp/externe/mail_mailEnergie.jsp";
            }

            log.debug("sujetmail =" + sujetMail + "url JSP =" + urlJsp);
        } catch (JMSException e) {
            log.error("Bad message type " + e);
            log.error(e);
        } catch (SQLException e) {
            log.error("Bad message type " + e);
            log.error(e);
        }
    }

    public void ejbCreate() {
    }

    /**
     *récupérattion du contexte jndi et message driven
     *Methode de callback
     */
    public void setMessageDrivenContext(
        MessageDrivenContext messageDrivenContext) {
        this.messageDrivenContext = messageDrivenContext;
    }
}

Configuration de la console WEBLOGIC


Penser à déclarer une Factory et une Queue sur la console weblogic dans les services.

A voir également

Publié par zieunoir.
Ce document intitulé «  Les EJBs JMS  » issu de CodeS-SourceS (codes-sources.commentcamarche.net) est mis à disposition sous les termes de la licence Creative Commons. Vous pouvez copier, modifier des copies de cette page, dans les conditions fixées par la licence, tant que cette note apparaît clairement.
Java et la synchronisation
Intégrer des images dans un jar avec Eclipse