 |
返回文章
清单 3.
SendServlet.java —— 一个用于发送 JMS 消息的 servlet
package com.ibm.dw.geronimo.jms;
...
public class SenderServlet extends HttpServlet {
...
private static final String QueueName =
"java:comp/env/dwSendReceiveQueue";
private static final String FactoryName =
"java:comp/env/DefaultActiveMQConnectionFactory";
public void init() throws ServletException {
super.init();
try {
jndiContext = new InitialContext();
factory = (QueueConnectionFactory)
jndiContext.lookup(FactoryName);
receiveQueue = (Queue)
jndiContext.lookup(QueueName);
}
catch (Exception ex) {
ex.printStackTrace();
}
}
public void destroy() {
...
}
public void doGet(HttpServletRequest req, HttpServletResponse res)
throws IOException, ServletException {
res.setContentType("text/html");
PrintWriter out = res.getWriter();
out.println("<html><head></head><body>");
out.println("<h2>Enter text message:</h2>");
out.println("<form method='post'>");
out.println("<input name='txtMsg' type='text' size='40'/>");
out.println("<br/><input type='submit' value='Send'/>");
out.println("</form></body></html>");
out.flush();
}
public void doPost(HttpServletRequest req, HttpServletResponse res)
throws IOException, ServletException {
....
try {
queueConn = factory.createQueueConnection();
queueSess = queueConn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
queueSender = queueSess.createSender(receiveQueue);
myMessage = queueSess.createTextMessage();
String msg = req.getParameter("txtMsg");
if (msg != null) {
myMessage.setText(msg);
queueSender.send(myMessage);
}
....
}
catch (Exception e) {
e.printStackTrace(System.out);
}
doGet(req, res);
}
}
|
返回文章
| |
|
