// EnviaColaTrans.java
// Alberto Rodriguez Galdo - tetoro@teleline.es - 6/2/2002

import javax.jms.*;
import javax.naming.*;

public class EnviaColaTrans{
	public static void main (String args[]){
		try{
			QueueConnectionFactory factory = null;
			QueueConnection  conexion = null;
    		QueueSession     sesion = null;
    		Queue            cola = null;
    		QueueSender   queueSender = null;
			InitialContext contexto = new InitialContext();
			factory = (QueueConnectionFactory)contexto.lookup("QueueConnectionFactory");
        	conexion = factory.createQueueConnection();
        	sesion = conexion.createQueueSession(true,Session.AUTO_ACKNOWLEDGE);
        	cola = (Queue)contexto.lookup("Cola");
        	queueSender = sesion.createSender(cola);
        	sesion.commit();
        	TextMessage mensaje1 = sesion.createTextMessage();
        	mensaje1.setText("mensaje1");
        	queueSender.send(mensaje1);
        	System.out.println("enviado " + mensaje1.getText());
        	sesion.commit();
        	System.out.println("commit");
        	mensaje1.setText("mensaje2");
        	queueSender.send(mensaje1);
        	System.out.println("enviado " + mensaje1.getText());
        	mensaje1.setText("mensaje3");
        	queueSender.send(mensaje1);
        	System.out.println("enviado " + mensaje1.getText());
        	sesion.rollback();
        	System.out.println("rollback");
        	mensaje1.setText("mensaje4");
        	queueSender.send(mensaje1);
        	System.out.println("enviado " + mensaje1.getText());
        	sesion.commit();
        	System.out.println("commit");
        	conexion.close();
        } catch (Exception e) {
        	System.out.println("problemas en EnviaColaTrans");
        	e.printStackTrace();
        }
	}
}