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