org.mule.transport.servlet.jetty

Class JettyMessageProcessTemplate

java.lang.Object

org.mule.transport.AbstractTransportMessageProcessTemplate

org.mule.transport.servlet.jetty.JettyMessageProcessTemplate

All Implemented Interfaces:

FlowProcessingPhaseTemplate, MessageProcessTemplate, RequestResponseFlowProcessingPhaseTemplate, ThrottlingPhaseTemplate, ValidationPhaseTemplate

Direct Known Subclasses:

JettyContinuationsMessageProcessTemplate

public class JettyMessageProcessTemplate
extends AbstractTransportMessageProcessTemplate
implements RequestResponseFlowProcessingPhaseTemplate, ThrottlingPhaseTemplate

Field Summary

Fields inherited from class org.mule.transport.AbstractTransportMessageProcessTemplate

logger

Constructor Summary

Constructors

Constructor and Description
JettyMessageProcessTemplate(HttpServletRequest request, HttpServletResponse response, AbstractMessageReceiver messageReceiver, MuleContext muleContext)

Method Summary

Methods

Modifier and Type	Method and Description
Object	acquireMessage() This method will only be called once for the MessageProcessContext
protected MuleMessage	createMessageFromSource(Object message)
void	discardMessageOnThrottlingExceeded() Discards the message due to ThrottlingPolicy configured for the MessageSource is exceeded
protected HttpServletResponse	getServletResponse()
protected ServletResponseWriter	getServletResponseWriter()
void	sendFailureResponseToClient(MessagingException messagingException)
void	sendResponseToClient(MuleEvent muleEvent) Template method to send a response after processing the message.
void	setThrottlingPolicyStatistics(long remainingRequestInCurrentPeriod, long maximumRequestAllowedPerPeriod, long timeUntilNextPeriodInMillis) Set up throttling policy state to be used by the MessageSource for debugging or information purpose.

Methods inherited from class org.mule.transport.AbstractTransportMessageProcessTemplate

afterFailureProcessingFlow, afterFailureProcessingFlow, afterRouteEvent, afterSuccessfulProcessingFlow, beforeRouteEvent, createEventFromMuleMessage, discardInvalidMessage, getConnector, getFlowConstruct, getInboundEndpoint, getMessageReceiver, getMuleContext, getMuleEvent, getOriginalMessage, getOutputStream, propagateRootMessageIdProperty, routeEvent, validateMessage, warnIfMuleClientSendUsed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mule.execution.FlowProcessingPhaseTemplate

afterFailureProcessingFlow, afterFailureProcessingFlow, afterRouteEvent, afterSuccessfulProcessingFlow, beforeRouteEvent, getMuleEvent, getOriginalMessage, routeEvent

Methods inherited from interface org.mule.execution.ThrottlingPhaseTemplate

getMuleEvent

Constructor Detail

JettyMessageProcessTemplate

public JettyMessageProcessTemplate(HttpServletRequest request,
                           HttpServletResponse response,
                           AbstractMessageReceiver messageReceiver,
                           MuleContext muleContext)

Method Detail

acquireMessage

public Object acquireMessage()
                      throws MuleException

Description copied from class: AbstractTransportMessageProcessTemplate

This method will only be called once for the MessageProcessContext

Specified by:

acquireMessage in class AbstractTransportMessageProcessTemplate

Returns:

the raw message from the MessageSource

Throws:

MuleException

createMessageFromSource

protected MuleMessage createMessageFromSource(Object message)
                                       throws MuleException

Overrides:

createMessageFromSource in class AbstractTransportMessageProcessTemplate

Throws:

MuleException

discardMessageOnThrottlingExceeded

public void discardMessageOnThrottlingExceeded()
                                        throws MuleException

Description copied from interface: ThrottlingPhaseTemplate

Discards the message due to ThrottlingPolicy configured for the MessageSource is exceeded

Specified by:

discardMessageOnThrottlingExceeded in interface ThrottlingPhaseTemplate

Throws:

MuleException

setThrottlingPolicyStatistics

public void setThrottlingPolicyStatistics(long remainingRequestInCurrentPeriod,
                                 long maximumRequestAllowedPerPeriod,
                                 long timeUntilNextPeriodInMillis)

Description copied from interface: ThrottlingPhaseTemplate

Set up throttling policy state to be used by the MessageSource for debugging or information purpose. Not all throttling policy supports statistics so this method may not be called

Specified by:

setThrottlingPolicyStatistics in interface ThrottlingPhaseTemplate

Parameters:

remainingRequestInCurrentPeriod - the remaining allowed messages in the current period

maximumRequestAllowedPerPeriod - the maximum allowed messages in a period

timeUntilNextPeriodInMillis - time in milliseconds until the next period starts

sendResponseToClient

public void sendResponseToClient(MuleEvent muleEvent)
                          throws MuleException

Description copied from interface: RequestResponseFlowProcessingPhaseTemplate

Template method to send a response after processing the message.

This method is executed within the flow so if it fails it will trigger the exception strategy.

Specified by:

sendResponseToClient in interface RequestResponseFlowProcessingPhaseTemplate

Parameters:

muleEvent - the event with the content of the response to be sent.

Throws:

MuleException - exception thrown when processing the message to send the response. If there's a failure when writing the response using the underlying transport or connector then the exception to throw must be a ResponseDispatchException.

sendFailureResponseToClient

public void sendFailureResponseToClient(MessagingException messagingException)
                                 throws MuleException

Specified by:

sendFailureResponseToClient in interface RequestResponseFlowProcessingPhaseTemplate

Parameters:

messagingException - exception thrown during the flow execution.

Throws:

MuleException - exception thrown when processing the message to send the response.

getServletResponseWriter

protected ServletResponseWriter getServletResponseWriter()

getServletResponse

protected HttpServletResponse getServletResponse()