org.activemq.web
Class MessageServlet
java.lang.Object
javax.servlet.GenericServlet
javax.servlet.http.HttpServlet
org.activemq.web.MessageServletSupport
org.activemq.web.MessageServlet
- All Implemented Interfaces:
- Serializable, Servlet, ServletConfig
public class MessageServlet
- extends MessageServletSupport
A servlet for sending and receiving messages to/from JMS destinations using
HTTP POST for sending and HTTP GET for receiving.
You can specify the
destination and whether it is a topic or queue via configuration details on
the servlet or as request parameters. For reading messages you can
specify a readTimeout parameter to determine how long the servlet should
block for.
- Version:
- $Revision: 1.1.1.1 $
- See Also:
- Serialized Form
Methods inherited from class org.activemq.web.MessageServletSupport |
appendParametersToMessage, asBoolean, asBoolean, asLong, createWebClient, getDestination, getDestination, getDestinationFromURI, getPostedMessageBody, getWebClient, init, isTopic |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageServlet
public MessageServlet()
init
public void init()
throws ServletException
- Overrides:
init
in class GenericServlet
- Throws:
ServletException
doPost
protected void doPost(HttpServletRequest request,
HttpServletResponse response)
throws ServletException,
IOException
- Sends a message to a destination
- Overrides:
doPost
in class HttpServlet
- Parameters:
request
- response
-
- Throws:
ServletException
IOException
doGet
protected void doGet(HttpServletRequest request,
HttpServletResponse response)
throws ServletException,
IOException
- Reads a message from a destination up to some specific timeout period
- Overrides:
doGet
in class HttpServlet
- Parameters:
request
- response
-
- Throws:
ServletException
IOException
doDelete
protected void doDelete(HttpServletRequest request,
HttpServletResponse response)
throws ServletException,
IOException
- Supports a HTTP DELETE to be equivlanent of consuming a message from a
queue
- Overrides:
doDelete
in class HttpServlet
- Throws:
ServletException
IOException
sendMessageResponse
protected void sendMessageResponse(HttpServletRequest request,
HttpServletResponse response,
Message message)
throws JMSException,
IOException
- Throws:
JMSException
IOException
isRicoAjax
protected boolean isRicoAjax(HttpServletRequest request)
getContentType
protected String getContentType(HttpServletRequest request)
setResponseHeaders
protected void setResponseHeaders(HttpServletResponse response,
Message message)
throws JMSException
- Throws:
JMSException
getReadTimeout
protected long getReadTimeout(HttpServletRequest request)
- Returns:
- the timeout value for read requests which is always >= 0 and <=
maximumReadTimeout to avoid DoS attacks
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.