| JMS: Java Message Service |
| Databases |
| Security Config |
| Third-Party Products |
SwiftMQ
The SwiftMQ client is configured by adding a jndi-link to the web.xml or resin.conf.
Resin needs the swiftmq.jar from the SwiftMQ distribution in the classpath, either in resin/lib/swiftmq.jar or in WEB-INF/lib.
<web-app>
<jndi-link>
<jndi-name>java:comp/env/jms</jndi-name>
<jndi-factory>com.swiftmq.jndi.InitialContextFactoryImpl</jndi-factory>
<init-param java.naming.provider.url="smqp://localhost:4001/timeout=10000"/>
</jndi-link>
|
The SwiftMQ router will need to be started as a separate process.
A sample servlet using the above SwiftMQ 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("QueueConnectionFactory");
queue = (Queue) jms.lookup("testqueue@router1");
} 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) {
}
}
}
}
|
| Databases |
| Security Config |
| Copyright © 1998-2006 Caucho Technology, Inc. All rights reserved. Resin® is a registered trademark, and HardCoretm and Quercustm are trademarks of Caucho Technology, Inc. |