|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ThrottlingPhaseTemplate
Template that a MessageSource
must implement
if it wants to participate in the throttling phase when processing a message
Method Summary | |
---|---|
void |
discardMessageOnThrottlingExceeded()
Discards the message due to ThrottlingPolicy configured for the MessageSource is exceeded |
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 interface org.mule.execution.FlowProcessingPhaseTemplate |
---|
afterFailureProcessingFlow, afterFailureProcessingFlow, afterRouteEvent, afterSuccessfulProcessingFlow, beforeRouteEvent, getMuleEvent, getOriginalMessage, routeEvent |
Method Detail |
---|
void discardMessageOnThrottlingExceeded() throws MuleException
MessageSource
is exceeded
MuleException
void setThrottlingPolicyStatistics(long remainingRequestInCurrentPeriod, long maximumRequestAllowedPerPeriod, long timeUntilNextPeriodInMillis)
MessageSource
for debugging or
information purpose.
Not all throttling policy supports statistics so this method may not be called
remainingRequestInCurrentPeriod
- the remaining allowed messages in the current periodmaximumRequestAllowedPerPeriod
- the maximum allowed messages in a periodtimeUntilNextPeriodInMillis
- time in milliseconds until the next period starts
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |