OpenJMS

The OpenJMS client is configured by adding a jndi-link to the web.xml or resin.conf.

Configured with OpenJMS tcp connectory

<web-app xmlns="http://caucho.com/ns/resin">
  <jndi-link jndi-name="jms"
             factory="org.exolab.jms.jndi.InitialContextFactory">
    <init-param java.naming.provider.url="tcp://localhost:3035"/>
  </jndi-link>
</web-app>

Configured with OpenJMS embedded

OpenJMS can also be embedded in Resin. Because OpenJMS does not yet support JCA, it does not understand server restarts. Therefore, it needs to be placed in the resin.conf, not the web.xml.

<resin xmlns="http://caucho.com/ns/resin">
  <server>
    <system-property openjms.home="/usr/local/src/openjms-0.7.6-rc3"/>
    <resource type="org.exolab.jms.server.EmbeddedJmsServer">
      <arg>${server.rootDir}/jms/openjms.xml</arg>
    </resource>

    <jndi-link jndi-name="jms"
               factory="org.exolab.jms.jndi.InitialContextFactory">
      <init-param java.naming.provider.url="embedded"/>
    </jndi-link>

    ...
</resin>

A sample servlet using the above OpenSSL configuration sends a text message to the queue.

package qa;

import java.io.*;
import javax.servlet.*;
import javax.servlet.http.*;
import javax.naming.*;
import javax.jms.*;

public class SendServlet extends HttpServlet {
  private QueueConnectionFactory _queueFactory;
  private Queue _queue;

  public void init()
    throws ServletException
  {
    try {
      Context ic = new InitialContext();
      Context jms = (Context) ic.lookup("java:comp/env/jms");

      _queueFactory = (QueueConnectionFactory)
        jms.lookup("JmsQueueConnectionFactory");

      _queue = (Queue) jms.lookup("queue1");
    } catch (Exception e) {
      throw new ServletException(e);
    }
  }

  public void service(HttpServletRequest req,
                      HttpServletResponse res)
    throws IOException, ServletException
  {
    PrintWriter out = res.getWriter();

    QueueConnection conn = null;

    try {
      conn = queueFactory.createQueueConnection();
      QueueSession queueSession =
         conn.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
      QueueSender queueSender = queueSession.createSender(queue);
      TextMessage message = queueSession.createTextMessage();

      message.setText("Test message");

      out.println("Sending message: " + message.getText());
      queueSender.send(message);
    } catch (Exception e) {
      throw new ServletException(e);
    } finally {
      try {
        conn.close();
      } catch (Exception e) {
      }
    }
  }
}