/*
 * receptorMensajesEJB.java
 *
 * Created on 3 de octubre de 2003, 16:11
 */

package mdbean;

/**
 *
 * @author Roberto Canales
 */
import java.io.Serializable;
import java.rmi.RemoteException;
import javax.ejb.EJBException;
import javax.ejb.MessageDrivenBean;
import javax.ejb.MessageDrivenContext;
import javax.ejb.CreateException;
import javax.naming.*;
import javax.jms.*;

public class receptorMensajesEJB implements MessageDrivenBean,  MessageListener
{
    private transient MessageDrivenContext mdc = null;
    private Context context;

    public receptorMensajesEJB() {
        depura("Constructor");
    }

    public void setMessageDrivenContext(MessageDrivenContext mdc) {
        depura("Establecemos el contexto");
	this.mdc = mdc;
    }

    public void ejbCreate() {
	depura("ejbCreate");
    }

    public void onMessage(Message inMessage) {
        depura("Recibido mensaje");

        TextMessage msg = null;

        try
        {
            if (inMessage instanceof TextMessage)
            {
                msg = (TextMessage) inMessage;
                depura("Mensaje recibido: " + msg.getText());
            } else {
                depura("Mensaje inadecuado: "+ inMessage.getClass().getName());
            }
        } catch (JMSException e)
        {
            e.printStackTrace();
            mdc.setRollbackOnly();
        }
        catch (Throwable te)
        {
            te.printStackTrace();
        }
    }  // fin del procesamiento del mensaje

    public void ejbRemove() {
        System.out.println("remove");
    }

    private void depura(String cadena)
    {
        System.out.println("EJB receptorMensajesEJB: " + cadena);
    }
} // fin de la clase

    

/**
 *
 * @author Roberto Canales
 */

package mdbean;

import javax.naming.*;
import javax.jms.*;
import java.util.*;


public class envioMensajeSimple {
    /** Punto de entrada a la aplicacion*/
    public static void main(String[] args) {
        envioMensajeSimple programa = new envioMensajeSimple();
        programa.arranca();
    }

    /** Funcion para centralizar mensajes*/
    void depura(String cadena) {
        System.out.println("Mensaje: " + cadena);
    }

    private static InitialContext getInitialContext() throws NamingException
    {
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");
        env.put("java.naming.factory.url.pkgs", "com.sun.enterprise.naming");
        env.put(Context.PROVIDER_URL, "iiop://127.0.0.1:1050");
        //env.put("org.omg.CORBA.ORBInitialHost","127.0.0.1");

        return new InitialContext(env);
    }

    /** Metodo encargado de ejecutar la tarea*/
    void arranca() {
        // inicializamos las variables
        Context jndiContext = null;
        Queue destino = null;
        QueueConnection  conexion = null;
        QueueSession  sesionActual = null;
        QueueSender  enviadorMensajes = null;
        TextMessage mensaje = null;


        // identificamos en nombre de la cola
        String colaDestino = "ColaRoberto";

        try {
            depura("Creamos un contexto");
             //jndiContext = new InitialContext();
            jndiContext = getInitialContext();
        }
        catch (NamingException e) {
            System.out.println("Imposible crear el contexto  " + "contexto: " + e.toString());
            System.exit(1);
        }

        try {
            // creamos el objeto para construir la conexion
            depura("Buscamos la factoria");
            QueueConnectionFactory queueConnectionFactory = (QueueConnectionFactory)jndiContext.lookup("QueueConnectionFactory");

            // localizamos la cola destino
            depura("Buscamos la cola");
            destino = (Queue) jndiContext.lookup(colaDestino);

            // creamos una conexión
            depura("Creamos la conexion");
            conexion = queueConnectionFactory.createQueueConnection();

            depura("Creamos la sesion");
            sesionActual = conexion.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

            // Creamos una factoria de mensaje y un mensaje
            depura("Creamos el productor de mensajes");

            enviadorMensajes = sesionActual.createSender(destino);

            mensaje = sesionActual.createTextMessage();
            mensaje.setStringProperty("TipoMensaje", "1");


           long inicio = System.currentTimeMillis();

           //for(int i=0;i<10;i++)
           //{
               // Asociamos texto al mensaje
                mensaje.setText("Nuevo mensaje " + new Date() );

                //depura("Enviamos el mensaje");
                enviadorMensajes.send(mensaje);
           //}
            enviadorMensajes.close();
            //productorMensajes.send(sesionActual.createMessage());


            long fin = System.currentTimeMillis() - inicio;
            System.out.println("El tiempo transcurrido es " + fin + " milisegundos");


        }
        catch (Exception e) {
            depura("Error en la aplicación " + e.toString());
            e.printStackTrace();
        }
        finally {
            if (conexion != null) {
                try {
                    conexion.close();
                }
                catch (JMSException e)
                {}
            }
        }

        depura("Salimos del programa");
    }
}