org.mule.runtime.module.http.internal.listener

Class HttpMessageProcessorTemplate

java.lang.Object

org.mule.runtime.module.http.internal.listener.HttpMessageProcessorTemplate

All Implemented Interfaces:

AsyncResponseFlowProcessingPhaseTemplate, MessageProcessTemplate, ThrottlingPhaseTemplate

public class HttpMessageProcessorTemplate
extends Object
implements AsyncResponseFlowProcessingPhaseTemplate, ThrottlingPhaseTemplate

Field Summary

Fields

Modifier and Type	Field and Description
static String	MESSAGE_DISCARD_MESSAGE_BODY
static String	MESSAGE_DISCARD_REASON_PHRASE
static int	MESSAGE_DISCARD_STATUS_CODE
static String	X_RATE_LIMIT_LIMIT_HEADER
static String	X_RATE_LIMIT_REMAINING_HEADER
static String	X_RATE_LIMIT_RESET_HEADER

Constructor Summary

Constructors

Constructor and Description
HttpMessageProcessorTemplate(Event sourceMuleEvent, Processor messageProcessor, HttpResponseReadyCallback responseReadyCallback, HttpResponseBuilder responseBuilder, HttpResponseBuilder errorResponseBuilder)

Method Summary

Modifier and Type	Method and Description
protected HttpResponse	buildErrorResponse()
protected HttpResponse	buildResponse(Event muleEvent, HttpResponseBuilder responseBuilder, ResponseCompletionCallback responseCompletationCallback)
void	discardMessageOnThrottlingExceeded()
protected HttpResponse	doBuildResponse(Event muleEvent, HttpResponseBuilder responseBuilder, ResponseCompletionCallback responseCompletationCallback)
Event	getEvent()
Event	routeEvent(Event muleEvent)
void	sendFailureResponseToClient(MessagingException messagingException, ResponseCompletionCallback responseCompletationCallback)
void	sendResponseToClient(Event event, ResponseCompletionCallback responseCompletationCallback)
void	setThrottlingPolicyStatistics(long remainingRequestInCurrentPeriod, long maximumRequestAllowedPerPeriod, long timeUntilNextPeriodInMillis)

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_DISCARD_STATUS_CODE

public static final int MESSAGE_DISCARD_STATUS_CODE

MESSAGE_DISCARD_MESSAGE_BODY

public static final String MESSAGE_DISCARD_MESSAGE_BODY

See Also:

Constant Field Values

MESSAGE_DISCARD_REASON_PHRASE

public static final String MESSAGE_DISCARD_REASON_PHRASE

See Also:

Constant Field Values

X_RATE_LIMIT_LIMIT_HEADER

public static final String X_RATE_LIMIT_LIMIT_HEADER

See Also:

Constant Field Values

X_RATE_LIMIT_REMAINING_HEADER

public static final String X_RATE_LIMIT_REMAINING_HEADER

See Also:

Constant Field Values

X_RATE_LIMIT_RESET_HEADER

public static final String X_RATE_LIMIT_RESET_HEADER

See Also:

Constant Field Values

Constructor Detail

HttpMessageProcessorTemplate

public HttpMessageProcessorTemplate(Event sourceMuleEvent,
                                    Processor messageProcessor,
                                    HttpResponseReadyCallback responseReadyCallback,
                                    HttpResponseBuilder responseBuilder,
                                    HttpResponseBuilder errorResponseBuilder)

Method Detail

getEvent

public Event getEvent()
               throws org.mule.runtime.api.exception.MuleException

Specified by:

getEvent in interface AsyncResponseFlowProcessingPhaseTemplate

Specified by:

getEvent in interface ThrottlingPhaseTemplate

Throws:

org.mule.runtime.api.exception.MuleException

routeEvent

public Event routeEvent(Event muleEvent)
                 throws org.mule.runtime.api.exception.MuleException

Specified by:

routeEvent in interface AsyncResponseFlowProcessingPhaseTemplate

Throws:

org.mule.runtime.api.exception.MuleException

sendResponseToClient

public void sendResponseToClient(Event event,
                                 ResponseCompletionCallback responseCompletationCallback)
                          throws org.mule.runtime.api.exception.MuleException

Specified by:

sendResponseToClient in interface AsyncResponseFlowProcessingPhaseTemplate

Throws:

org.mule.runtime.api.exception.MuleException

buildErrorResponse

protected HttpResponse buildErrorResponse()

buildResponse

protected HttpResponse buildResponse(Event muleEvent,
                                     HttpResponseBuilder responseBuilder,
                                     ResponseCompletionCallback responseCompletationCallback)

doBuildResponse

protected HttpResponse doBuildResponse(Event muleEvent,
                                       HttpResponseBuilder responseBuilder,
                                       ResponseCompletionCallback responseCompletationCallback)

sendFailureResponseToClient

public void sendFailureResponseToClient(MessagingException messagingException,
                                        ResponseCompletionCallback responseCompletationCallback)
                                 throws org.mule.runtime.api.exception.MuleException

Specified by:

sendFailureResponseToClient in interface AsyncResponseFlowProcessingPhaseTemplate

Throws:

org.mule.runtime.api.exception.MuleException

discardMessageOnThrottlingExceeded

public void discardMessageOnThrottlingExceeded()
                                        throws org.mule.runtime.api.exception.MuleException

Specified by:

discardMessageOnThrottlingExceeded in interface ThrottlingPhaseTemplate

Throws:

org.mule.runtime.api.exception.MuleException

setThrottlingPolicyStatistics

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

Specified by:

setThrottlingPolicyStatistics in interface ThrottlingPhaseTemplate