public class MessageServlet extends MessageServletSupport
Constructor and Description |
---|
MessageServlet() |
Modifier and Type | Method and Description |
---|---|
protected void |
closeConsumerOnOneShot(javax.servlet.http.HttpServletRequest request,
WebClient client,
javax.jms.Destination dest)
Close the consumer if one-shot mode is used on the given request.
|
protected void |
doDelete(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
Supports a HTTP DELETE to be equivalent of consuming a singe message
from a queue
|
protected void |
doGet(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
Supports a HTTP DELETE to be equivalent of consuming a singe message
from a queue
|
protected void |
doMessages(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
Reads a message from a destination up to some specific timeout period
|
protected void |
doPost(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
Sends a message to a destination
|
protected String |
getContentType(javax.servlet.http.HttpServletRequest request) |
protected long |
getReadDeadline(javax.servlet.http.HttpServletRequest request) |
WebClient |
getWebClient(javax.servlet.http.HttpServletRequest request) |
protected void |
handleContinuation(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
WebClient client,
javax.jms.Destination destination,
org.apache.activemq.MessageAvailableConsumer consumer,
long deadline) |
void |
init() |
protected boolean |
isXmlContent(javax.jms.Message message) |
protected void |
setResponseHeaders(javax.servlet.http.HttpServletResponse response,
javax.jms.Message message) |
protected void |
writeMessageResponse(PrintWriter writer,
javax.jms.Message message) |
protected void |
writeResponse(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response,
javax.jms.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
public MessageServlet()
public void init() throws javax.servlet.ServletException
init
in class javax.servlet.GenericServlet
javax.servlet.ServletException
protected void doPost(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws javax.servlet.ServletException, IOException
doPost
in class javax.servlet.http.HttpServlet
request
- response
- javax.servlet.ServletException
IOException
protected void doDelete(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws javax.servlet.ServletException, IOException
doDelete
in class javax.servlet.http.HttpServlet
javax.servlet.ServletException
IOException
protected void doGet(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws javax.servlet.ServletException, IOException
doGet
in class javax.servlet.http.HttpServlet
javax.servlet.ServletException
IOException
protected void doMessages(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) throws javax.servlet.ServletException, IOException
request
- response
- javax.servlet.ServletException
IOException
protected void handleContinuation(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, WebClient client, javax.jms.Destination destination, org.apache.activemq.MessageAvailableConsumer consumer, long deadline)
protected void writeResponse(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, javax.jms.Message message) throws IOException, javax.jms.JMSException
IOException
javax.jms.JMSException
protected void writeMessageResponse(PrintWriter writer, javax.jms.Message message) throws javax.jms.JMSException, IOException
javax.jms.JMSException
IOException
protected boolean isXmlContent(javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
public WebClient getWebClient(javax.servlet.http.HttpServletRequest request)
protected String getContentType(javax.servlet.http.HttpServletRequest request)
protected void setResponseHeaders(javax.servlet.http.HttpServletResponse response, javax.jms.Message message) throws javax.jms.JMSException
javax.jms.JMSException
protected long getReadDeadline(javax.servlet.http.HttpServletRequest request)
protected void closeConsumerOnOneShot(javax.servlet.http.HttpServletRequest request, WebClient client, javax.jms.Destination dest)
Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.