public class MessageServlet extends MessageServletSupport
Constructor and Description |
---|
MessageServlet() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeConsumerOnOneShot(HttpServletRequest request,
WebClient client,
Destination dest)
Close the consumer if one-shot mode is used on the given request.
|
protected void |
doDelete(HttpServletRequest request,
HttpServletResponse response)
Supports a HTTP DELETE to be equivalent of consuming a singe message
from a queue
|
protected void |
doGet(HttpServletRequest request,
HttpServletResponse response)
Supports a HTTP DELETE to be equivalent of consuming a singe message
from a queue
|
protected void |
doMessages(HttpServletRequest request,
HttpServletResponse response)
Reads a message from a destination up to some specific timeout period
|
protected void |
doPost(HttpServletRequest request,
HttpServletResponse response)
Sends a message to a destination
|
protected String |
getContentType(HttpServletRequest request) |
protected long |
getReadDeadline(HttpServletRequest request) |
WebClient |
getWebClient(HttpServletRequest request) |
protected void |
handleContinuation(HttpServletRequest request,
HttpServletResponse response,
WebClient client,
Destination destination,
org.apache.activemq.MessageAvailableConsumer consumer,
long deadline) |
void |
init() |
protected boolean |
isXmlContent(Message message) |
protected void |
setResponseHeaders(HttpServletResponse response,
Message message) |
protected void |
writeMessageResponse(PrintWriter writer,
Message message) |
protected void |
writeResponse(HttpServletRequest request,
HttpServletResponse response,
Message message) |
appendParametersToMessage, asBoolean, asBoolean, asDestination, asInt, asInteger, asLong, asLong, asString, getDestination, getDestination, getDestinationFromURI, getPostedMessageBody, getSelector, getSendPriority, getSendTimeToLive, init, isSendPersistent, isSync, isTopic
doHead, doOptions, doPut, doTrace, getLastModified, service, service
destroy, getInitParameter, getInitParameterNames, getServletConfig, getServletContext, getServletInfo, getServletName, log, log
public MessageServlet()
public void init() throws ServletException
init
in class GenericServlet
ServletException
protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
doPost
in class HttpServlet
request
- response
- ServletException
IOException
protected void doDelete(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
doDelete
in class HttpServlet
ServletException
IOException
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
doGet
in class HttpServlet
ServletException
IOException
protected void doMessages(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
request
- response
- ServletException
IOException
protected void handleContinuation(HttpServletRequest request, HttpServletResponse response, WebClient client, Destination destination, org.apache.activemq.MessageAvailableConsumer consumer, long deadline)
protected void writeResponse(HttpServletRequest request, HttpServletResponse response, Message message) throws IOException, JMSException
IOException
JMSException
protected void writeMessageResponse(PrintWriter writer, Message message) throws JMSException, IOException
JMSException
IOException
protected boolean isXmlContent(Message message) throws JMSException
JMSException
public WebClient getWebClient(HttpServletRequest request)
protected String getContentType(HttpServletRequest request)
protected void setResponseHeaders(HttpServletResponse response, Message message) throws JMSException
JMSException
protected long getReadDeadline(HttpServletRequest request)
protected void closeConsumerOnOneShot(HttpServletRequest request, WebClient client, Destination dest)
Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.