 |
Return to article
An EJB component accesses a message queue resource, using connection objects
// Use JNDI to find the connection factory and the destination
Context ctx = new InitialContext();
QueueConnectionFactory factory = (QueueConnectionFactory) ctx.lookup("java:comp/env/jms/theFactory");
Queue queue = (Queue) ctx.lookup("java:comp/env/jms/theQueue");
// create a connection, session, sender, and the message QueueConnection conn;
QueueConnection conn = factory.createQueueConnection("myUserName", "myPassword");
QueueSession session = connection.createQueueSession (false, Session.AUTO_ACKNOWLEDGE);
QueueSender sender = session.createSender(queue);
...
// start up the connection, send the message
connection.start();
sender.send("Message");
connection.stop();
// now close all resources to ensure that native resources are released
sender.close();
session.close();
connection.close();
|
Return to article
|  |
|