Construir Aplicaciones EJB con JBoss, Lomboz y Eclipse

Esta cap�tulo cubre c�mo crear un Bean Dirigido por Mensaje (MDB). Crear� dos beans MDB, DeliverItems y RequestItems. El primero rellenar� los stocks de varios �tems de MyStore, y RequestItems enviar� peticiones a varios proveedores para que que env�en �tems que est�n fuera de stock. El manager de MyStore generar�/enviar� esta petici�n.

�Crear el Bean MDB RequestItems:

• Ve a Package Explorer expande el nodo del proyecto Mystore, selecciona src y pulsa el bot�n derecho.
• En el men� que aparece elige New > Lomboz EJB Creation Wizard.
• Introduce au.com.tusc.mdb como el nombre del paquete, RequestItems como el nombre del bean y selecciona el tipo como Message Drive Bean (Queue):
  
• Pulsa Finish.

Esto crear� un paquete llamado au.com.tusc.mdb en src y el bean RequestItemsBean dentro de ese paquete:

Se crea una etiqueta @ejb.bean que asigna el nombre, el tipo de transaci�n, el tipo de destino y algunas otras propiedades que puedes ver abajo:

Al contrario que los beans anteriores �ste tiene un m�todo setMessageContext para configurar el contexto:

Tiene los m�todos ejbCreate y ejbRemove al igual que los otros tipos de beans:

Tiene un nuevo m�todo llamado onMessage que es uno de los m�s importantes para nosotros, es donde escribiremos toda la l�gica de negocio:

Una vez que se recibe un mensaje del productor JMS como un objeto Message, se extraen sus datos y se rellena un objeto de valor inmutable con esos datos y luego se transfiere al bean principal. Esto lo cubriremos m�s tarde.

Ahora, antes de a�adir cualquier funcionalidad, crearemos una clase u objeto de valor inmutable para extraer informaci�n del mensaje.

�Crear un Objeto de Valor Inmutable para RequestItem:

• Ve a src bajo el paquete au.com.tusc.mdb elige New >Class
  
• Aparecer� el wizard de clases Java, elige Add y selecciona el nombre de la clase como RequestItem, la Superclase como java.lang.Object y el Interface como Serializable como se ve en la siguiente figura:
  

  Esto generar� la clase RequestItem en el paquete au.com.tusc.mdb.

• A�ade los siguientes atributos a la clase RequestItem:

  private String username;
  private String passwd;
  private String itemID;
  private int quantity;
  

• Para a�adir m�todos accesores y mutadores para esos atributos; seleccionalos todos, pulsa con el bot�n derecho y selecciona source > Generate Getter and Setter como se ve abajo:
  
• A�ade un constructor para la clase que tenga par�metros de los mismos tipos que los atributos y asign�los a los atributos:
  

Ya est� completo el constructor de RequestItem, ahora nos falta implementar el m�todo onMessage del bean RequestItem.

�Implementar el m�todo onMessage:

Este m�todo es responsable de extraer informaci�n del mensaje y transferirla al bean principal. Un Manager de MyStore chequear� los �tems que est�n fuera de stock y genera una petici�n a los proveedores especificando el itemID y la cantidad necesaria.

• Primero importa los paquetes java.util.ArrayList y java.util.Iterator.
• A�ade las siguientes variables para almacenar referencias:

  ArrayList outOfStockItems = null;       
  Iterator itemsIterator = null;
  private StoreAccessHome storeAccess = null;
  private SupplierLocalHome suppLocalHome = null;
  private ItemLocalHome itemLocalHome = null;
  

• Extrae los datos del mensaje en el objeto de valor inmutable como se muestra abajo:

  RequestItem ri =  (RequestItem) ((ObjectMessage) message).getObject();
  

• A�ade estas l�neas de c�digo para que el manager pueda hacer el login:

  StoreAccess access = StoreAccessUtil.getHome().create();                                
  String mgrAccessID = access.loginUser(ri.getUsername(),ri.getPasswd()); 
  

• Obt�n los �tems con stock 0, llamando a getOutOfStockItems() del bean StoreAccess (que devuelve una Collection):

  outOfStockItems = access.getOutOfStockItems();
  

• Ahora, itera sobre cada �tem, obt�n el supplierId asociado con �l llamando a los m�todos finder del bean Supplier, y finalmente env�a el mensaje a ese proveedor llamando al m�todo de negocio requestItem() sobre el bean Supplier:

  itemsIterator = outOfStockItems.iterator();
  
  while ( itemsIterator.hasNext() ) {                     
      ItemData itemData= ( ItemData ) itemsIterator.next();
      String suppID = itemData.getSupplierID();
      SupplierLocal supplier = this.suppLocalHome.findByPrimaryKey(suppID);
      Integer quantity = new Integer (ri.getQuantity());
      String itemID = ri.getItemID();
      supplier.requestItem( itemID, quantity); 
  } 
  

Abajo puedes ver el c�digo del m�todo onMessage:

Nuestro bean est� completo, y s�lo nos faltan los descriptores de despliegue para el bean.

�Desplegar el Bean RequestItems:

Para desplegar este bean tenemos que a�adir unos cuantos descriptores de despliegue. Como se ve abajo, se han a�adido cinco etiquetas:

• Primero a�ade la siguiente etiqueta a nivel de clase en el bean RequestItems, para obtener una referencia a StoreAccessBean, para poder invocar a sus m�todos:

  @ejb.ejb-ref
  ejb-name="StoreAccess"
  view-type="remote"
  ref-name="StoreAccess"
  

  Esta etiqueta generar� los descriptores de despliegue en ejb-jar.xml cuando generes tus clases EJB, ya que este bean de mensaje tiene que autenticarse, antes de transferir la informaci�n al bean principal. Generar� los siguientes descriptores de despliegue:

  
• A�ade esta otra etiqueta, para obtener una referencia al bean Supplier en este bean:

  @ejb.ejb-ref
  ejb-name="Supplier"
  view-type="local"
  ref-name="SupplierLocal"
  

  Esta etiqueta generar� los descriptores de despliegue en ejb-jar.xml cuando generes tus clases EJB, ya que este bean de mensaje transfiere informaci�n al bean Supplier. Se generar�n estos descriptores de despliegue:

  

Nota: Otro descriptor que se ha generado es <ejb-name>, que ha sido generado por la etiqueta @ejb.bean que a�adi� el EJB creation wizard. Esta etiqueta genera los siguientes descriptores de despliegue en ejb-jar.xml:

• A�ade la siguiente etiqueta. Esta etiqueta es espec�fica de JBOSS, y se utiliza para registrar el bean dirigido por mensaje con un nombre JNDI, utilizando el formato "queue/name":

  @jboss.destination-jndi-name 
  name="queue/MdbQueue"
  

  Esta etiqueta genera los siguientes descriptores de despliegue en jboss.xml:

  
• A�ade esta otra etiqueta, necesaria para que JBOSS pueda encontrar el bean Supplier utilizando su nombre JNDI:

  @jboss.ejb-ref-jndi ref-name="SupplierLocal"
   jndi-name="SupplierLocal"
  

  Nota: Como se explic� en p�ginas anteriores, esta etiqueta genera descriptores incorrectos dentro de jboss.xml. Para view-type="local" genera una etiqueta <ejb-ref> en vez de <ejb-local-ref>.

• Corrige las siguientes etiquetas:
  

  Busca estas etiquetas en jboss.xml y cambialas como <ejb-local-ref> seg�n la siguiente figura:

  
• Ahora a�de esta �ltima etiqueta en el bean StoreAccess, para referenciarlo utilizando su nombre JNDI:

  @jboss.ejb-ref-jndi ref-name="StoreAccess"
  jndi-name="StoreAccessBean"
  

  Esta etiqueta generar� los siguientes descriptores de despliegue en jboss.xml:

  

Ahora ya est� completo nuestro bean RequestItems, a�ade tu bean y genera las clases EJB:

• Ve al nodo RequestItemsBean en el paquete au.com.tusc.mdb, pulsa con el bot�n derecho y selecciona Lomboz J2EE... > Add EJB to Module y pulsa Ok.
• Ve al nodo MyStoreMgr en el explorador de paquetes, pulsa con el bot�n derecho, y selecciona Lomboz J2EE... > Generate EJB classes.

  Nota: Como has regenerado tus clases de nuevo, tendr�s que corregir los descriptores de despliegue incorrectos de jboss.xml, dentro de <message-driven> y <session>.

• Ahora para desplegar el bean, ve a Lomboz J2EE View, arranca el servidor si no lo est� y despliega el bean.

Los mensajes de la consola te dir�n el estado del despliegue. Ahora nos falta crear nuestro test de cliente.

�Crear el Test de Cliente:

En este caso no nos servir� el Test Client Wizard para crear el test de cliente, porque requiere que seleccionemos un interface Home y un interface EJB, y los beans dirigidos por mensaje no tienen este tipo de interfaces.

Por eso tenemos que escribir una clase y los m�todos necesarios para llamar a las operaciones sobre el bean RequestItems.

• A�ade una clase llamada RequestMDBClient al paquete au.com.tusc.mdb
• A�ade un m�todo llamado getContext con la siguiente firma:

  private InitialContext getContext() throws NamingException 
  

• A�ade las siguientes l�neas de c�digo para obtener el ejemplar de IntialContext:
  
• A�ade un m�todo llamado testMDBBean con la siguiente firma:

  public void testMDBBean()
  

• Ahora implementa este m�todo, utilizando estos pasos:
  1. A�ade un Data Object que se enviar� como mensaje.
  2. Crea una referencia al contexto inicial.
  3. Crea una referencia a la factor�a conexiones.
  4. Utiliza este contexto para realizar la b�squeda, donde el string de b�squeda es "queue/MdbQueue".
  5. Crea la QueueConnection.
  6. Crea el QueueSender.
  7. Crea la QueueSession para el bean.
  8. Crea el objeto Message para el Data Object en el mensaje.
  9. Env�a el mensaje.
  10. Finalmente, env�a la sesi�n, y luego cierra tanto la sesi�n como la conexi�n.

  Aqu� puedes ver un fragmento de c�digo del m�todo testMDBean:

  

El test de cliente ya est� completo, vamos a probarlo!

�Probar el Cliente:

• Para probar el cliente, selecciona el nodo RequestMDBClient, ve al men� superior y selecciona el icono del "hombre corriendo".
• En �l, selecciona Run as y luego Java Application.
• Ahora, en la consola deber�as obtener los siguientes mensajes:
  

  Este mensaje no nos dice si se ha enviado o no el mensaje al bean principal. Para verificar esto, ve a la base de datos utilizando JMX Management Console View > Hypersonic > Invoke Database Manager y ejecuta una consulta sobre la tabla supplier para ver si se ha a�adido un mensaje a alg�n proveedor.

  

  Nota: Los detalles de c�mo acceder a este Database Manager se vieron en la primera p�gina de este tutorial.

  Como un proveedor llamado Sebastian ha recibido nuestro mensaje, significa que nuestro bean funciona correctamente.

�Ejercicio:

Ahora para seguir progresando, por favor completa el siguiente ejercicio para implementar DeliverItems como un bean MD. Aqu� tienes la lista de tareas:

1. Crea un bean MD lamado DeliverItems en el paquete au.com.tusc.mdb.
2. Crea un objeto de valor inmutable llamado DeliverItem en el paquete au.com.tusc.mdb. A�adele algunos atributos e implementa sus m�todos accesores y mutadores:

   private String username
   private String passwd
   private String itemID
   private int quantity
   

3. Implementa el m�todo onMessage en DeliverItems:
   • A�ade estas dos variables para almacenar referencias:

     private StoreAccessHome storeAccess = null;
     private ItemLocalHome itemLocalHome = null;
     

   • Extrae los datos del mensaje en tu objeto de valor inmutable de esta forma:

     DelieverItem di =  (DeliverItem) ((ObjectMessage) message).getObject();
     

   • Obt�n las referencias de los beans StoreAccess e Item:

     StoreAccess access = StoreAccessUtil.getHome().create();
     itemLocalHome = ItemUtil.getLocalHome();
     

   • LLama al m�todo loginUser de supplier para obtener su userid(accessID) y luego encontrar la ID del proveedor llamado al m�todo getSupplierData:

     String suppAcessID = access.loginUser(di.getUsername(), di.getPasswd());
     SupplierData sd = access.getSupplierData(suppAccessID);
     String suppID = sd.getSupplierID();
     

   • Si suppID no es null, llama al m�todo finder del bean Item para obtener los detalles de los �tems a entregar, extrayendo itemID del mensaje:

     ItemLocal item = this.itemLocalHome.findByPrimaryKey(di.getItemID());
     

   • Obt�n la ID del proveedor asociada con el �tem encontrado, para poder actualizar el stock:

     String itemSuppID = item.getSupplierID();
     

   • Compara itemSuppID e ItemID, si son iguales actualiza el stock de ese �tem llamado al m�todo fillStock del bean Item:

     if ( suppID.equals(itemSuppID)) {
         System.out.println ("Delivering items in store now... :");
         Integer quantity = new Integer (di.getQuantity());
         item.fillStock(quantity);
         System.out.println ("Stock of iten after dleivery is :" + item.getItemData());
     }
     

4. A�ade las siguientes etiquetas para el despliegue a nivel de clase para enlazar/referenciar a Supplier:

   1. @ejb.ejb-ref
       ejb-name="StoreAccess"
       view-type="remote"
       ref-name="StoreAccess"
   
   2. @ejb.ejb-ref
       ejb-name="Item"
       view-type="local"
       ref-name="ItemLocal"
   
   3. @jboss.ejb-ref-jndi ref-name="ItemLocal"
       jndi-name="ItemLocal"
   
   4. @jboss.ejb-ref-jndi ref-name="StoreAccess"
       jndi-name="StoreAccessBean"
    
   5. @jboss.destination-jndi-name
        name="queue/DelMdbQueue"
   

5. Despliega el bean DeliverItems.
6. Crea un test de cliente llamado DeliverMDBClient en le paquete au.com.tusc.mdb.
7. a�ade un m�todo llamado testMDBBean con la siguiente firma:

   public void testMDBBean

8. Implementa testMDBBean; aqu� tienes unas pistas:
   • A�ade un Data Object que se envi� como mensaje.
   • Crea el contexto inicial.
   • Crea una factor�a de conexiones.
   • Utiliza este contexto para realizar la b�squeda JNDI con el string "queue/DelMdbQueue".
   • Crea la QueueConnection.
   • Crea el QueueSender.
   • Crea la QueueSession para el bean.
   • Crea el objeto Message y pas�le el Data Object en el mensaje.
   • Env�a el mensaje.
   • Finalmente, env�a la sesi�n y cierra la sesi�n y la conexi�n.
9. Ejecuta el cliente y prueba el bean: