...
- Code your servlet to use JNDI lookups to access and operate on these resources. For example, here's the code snippets to put a message onto a queue (a these full example is available MyQueueServlet.java):
| Code Block |
|---|
private QueueConnectionFactory connectionFactory;
private Queue myQueue;
public void init(ServletConfig config) throws ServletException
{
super.init(config);
try
{
InitialContext ic = new InitialContext();
connectionFactory = (QueueConnectionFactory)ic.lookup("java:comp/env/jms/connectionFactory");
myQueue = (Queue)ic.lookup("java:comp/env/jms/myQueue");
}
catch (Exception e)
{
e.printStackTrace();
throw new ServletException(e);
}
}
.
.
.
public void sendMessage(String msg)
throws Exception
{
QueueConnection connection = null;
QueueSession session = null;
MessageProducer producer = null;
try
{
connection = connectionFactory.createQueueConnection();
session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
producer = session.createProducer(myQueue);
TextMessage message = session.createTextMessage(msg);
producer.send(message);
}
finally
{
try
{
if (producer!=null)producer.close();
if (session!=null)session.close();
if (connection!=null)connection.close();
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
|