org.mule.transport.servlet.jetty

Class JettyContinuationsMessageProcessTemplate

java.lang.Object

org.mule.transport.AbstractTransportMessageProcessTemplate

org.mule.transport.servlet.jetty.JettyMessageProcessTemplate

org.mule.transport.servlet.jetty.JettyContinuationsMessageProcessTemplate

All Implemented Interfaces:

EndPhaseTemplate, FlowProcessingPhaseTemplate, MessageProcessTemplate, RequestResponseFlowProcessingPhaseTemplate, ThrottlingPhaseTemplate, ValidationPhaseTemplate

public class JettyContinuationsMessageProcessTemplate
extends JettyMessageProcessTemplate
implements EndPhaseTemplate

Field Summary

Fields inherited from class org.mule.transport.AbstractTransportMessageProcessTemplate

logger

Constructor Summary

Constructors

Constructor and Description
JettyContinuationsMessageProcessTemplate(HttpServletRequest request, HttpServletResponse response, AbstractMessageReceiver messageReceiver, MuleContext muleContext, org.eclipse.jetty.continuation.Continuation continuation)

Method Summary

Methods

Modifier and Type	Method and Description
void	completeProcessingRequest()
void	discardMessageOnThrottlingExceeded() Discards the message due to ThrottlingPolicy configured for the MessageSource is exceeded
void	messageProcessingEnded() template method call when the message processing ends
void	sendFailureResponseToClient(MessagingException messagingException)
void	sendResponseToClient(MuleEvent muleEvent) Template method to send a response after processing the message.
void	suspended()

Methods inherited from class org.mule.transport.servlet.jetty.JettyMessageProcessTemplate

acquireMessage, afterFailureProcessingFlow, createMessageFromSource, getServletResponse, getServletResponseWriter, setThrottlingPolicyStatistics

Methods inherited from class org.mule.transport.AbstractTransportMessageProcessTemplate

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, afterRouteEvent, afterSuccessfulProcessingFlow, beforeRouteEvent, getMuleEvent, getOriginalMessage, routeEvent

Methods inherited from interface org.mule.execution.ThrottlingPhaseTemplate

getMuleEvent

Constructor Detail

JettyContinuationsMessageProcessTemplate

public JettyContinuationsMessageProcessTemplate(HttpServletRequest request,
                                        HttpServletResponse response,
                                        AbstractMessageReceiver messageReceiver,
                                        MuleContext muleContext,
                                        org.eclipse.jetty.continuation.Continuation continuation)

Method Detail

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

Overrides:

sendResponseToClient in class JettyMessageProcessTemplate

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

Overrides:

sendFailureResponseToClient in class JettyMessageProcessTemplate

Parameters:

messagingException - exception thrown during the flow execution.

Throws:

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

completeProcessingRequest

public void completeProcessingRequest()

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

Overrides:

discardMessageOnThrottlingExceeded in class JettyMessageProcessTemplate

Throws:

MuleException

suspended

public void suspended()

messageProcessingEnded

public void messageProcessingEnded()

Description copied from interface: EndPhaseTemplate

template method call when the message processing ends

Specified by:

messageProcessingEnded in interface EndPhaseTemplate