Como conectarse a una cola JMS en Weblogic8.16

Bien facil:

private QueueConnectionFactory qcf = null;
private Queue destQueue= null;
private QueueConnection connJms = null;
private QueueSession session = null;

public void init() {
        try
        {
            InitialContext ctx = new InitialContext();
            qcf = (QueueConnectionFactory)ctx.lookup("NOMBRE DE LA FACTORY");
            destQueue=(Queue)ctx.lookup("NOMBRE DE LA COLA");
            ctx.close();
        }
        catch(Exception e)
        {
            e.printStackTrace();
        }
    }


public void registro(String mess) throws EJBException {
        try {
            TextMessage msg = null;
           
            connJms = qcf.createQueueConnection();
            session = connJms.createQueueSession(true,Session.AUTO_ACKNOWLEDGE);
            {
                QueueSender sender = session.createSender(destQueue);
                msg = session.createTextMessage(mess);
                sender.send(msg);
            }           
            commit(session);
        } catch (Exception e) {
            rollback(session);
            throw new EJBException(e);
        } finally {
//siempre cerrar la conexion
            close(connJms);
        }
    }

private void close(QueueConnection connJms) {
        if (connJms != null)
            try {
                connJms.close();
            } catch (Exception e) {
                e.printStackTrace();
            }
    }

0 comentarios:

Publicar un comentario

Copyright © Innovacion & Movilidad