Class EnqueueMediator
- java.lang.Object
-
- org.apache.synapse.mediators.AbstractMediator
-
- org.apache.synapse.mediators.builtin.EnqueueMediator
-
- All Implemented Interfaces:
AspectConfigurable
,Mediator
,SynapseArtifact
public class EnqueueMediator extends AbstractMediator
This mediator execute a given sequence with a given priority. It accepts the priority as and argument. The executor used for executing this sequence should support this priority. If it doesn't support this priority it executor can throw exceptions.
-
-
Field Summary
-
Fields inherited from class org.apache.synapse.mediators.AbstractMediator
log, trace, traceState
-
-
Constructor Summary
Constructors Constructor Description EnqueueMediator()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getExecutorName()
int
getPriority()
String
getSequenceName()
boolean
isContentAware()
boolean
mediate(MessageContext synCtx)
Invokes the mediator passing the current message for mediation.void
setExecutorName(String executorName)
void
setPriority(int priority)
void
setSequenceName(String sequenceName)
-
Methods inherited from class org.apache.synapse.mediators.AbstractMediator
auditLog, auditWarn, configure, disableStatistics, disableTracing, divertMediationRoute, enableStatistics, enableTracing, getAspectConfiguration, getCommentsList, getDescription, getInputType, getLastSequenceFaultHandler, getLog, getMediatorName, getMediatorPosition, getOutputType, getRegisteredMediationFlowPoint, getShortDescription, getTraceState, getType, handleException, handleException, isBreakPoint, isContentAltering, isSkipEnabled, isStatisticsEnable, isTraceOn, isTraceOrDebugOn, isTracingEnabled, registerMediationFlowPoint, reportCloseStatistics, reportOpenStatistics, setBreakPoint, setCommentsList, setComponentStatisticsId, setDescription, setEffectiveTraceState, setMediatorPosition, setShortDescription, setSkipEnabled, setTraceState, shouldCaptureTracing, shouldTrace, shouldTrace, traceOrDebug, traceOrDebugWarn, unregisterMediationFlowPoint
-
-
-
-
Method Detail
-
mediate
public boolean mediate(MessageContext synCtx)
Description copied from interface:Mediator
Invokes the mediator passing the current message for mediation. Each mediator performs its mediation action, and returns true if mediation should continue, or false if further mediation should be aborted.- Parameters:
synCtx
- the current message for mediation- Returns:
- true if further mediation should continue
-
getExecutorName
public String getExecutorName()
-
getPriority
public int getPriority()
-
getSequenceName
public String getSequenceName()
-
setExecutorName
public void setExecutorName(String executorName)
-
setPriority
public void setPriority(int priority)
-
setSequenceName
public void setSequenceName(String sequenceName)
-
isContentAware
public boolean isContentAware()
- Specified by:
isContentAware
in interfaceMediator
- Overrides:
isContentAware
in classAbstractMediator
-
-