Integrating with ActiveMQ

    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();
          }
        }
    }