ActiveMQ+Spring+Maven Demo

package com.mq.demo; import java.io.IOException; import java.io.PrintWriter; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.jms.core.JmsTemplate; import org.springframework.web.context.WebApplicationContext; import org.springframework.web.context.support.WebApplicationContextUtils; public class SendServlet extends HttpServlet { private Logger logger = LoggerFactory.getLogger(getClass()); /** * */ private static final long serialVersionUID = 1L; private JmsTemplate jmsTemplate; @Override public void init() throws ServletException { super.init(); WebApplicationContext cx = WebApplicationContextUtils .getWebApplicationContext(getServletContext()); jmsTemplate = (JmsTemplate) cx.getBean("jmsTemplate"); } @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { doPost(req, resp); } @Override protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { String title = req.getParameter("title"); String body = req.getParameter("body"); PrintWriter pw = null; try{ pw = resp.getWriter(); if(StringUtils.isBlank(title) || StringUtils.isBlank(body)){ pw.write("<h1>Message title/body is null.</h1>"); pw.flush(); return; } MessageBean message = new MessageBean(); message.setMsgName(title); message.setMsgBody(body); Sender.sender(jmsTemplate, message); pw.write("<h2>Send Sucessful.</h2>"); pw.flush(); }catch(Throwable e){ logger.error("Occured Exception:", e); }finally{ if(null != pw){ pw.close(); } } } }