public class AggregateMediator extends AbstractMediator implements ManagedLifecycle, FlowContinuableMediator
trace, traceState
Constructor and Description |
---|
AggregateMediator() |
Modifier and Type | Method and Description |
---|---|
boolean |
completeAggregate(Aggregate aggregate)
Invoked by the Aggregate objects that are timed out, to signal timeout/completion of
itself
|
void |
destroy()
This method should implement the destroying of the
implemented parts of the configuration.
|
Map |
getActiveAggregates() |
SynapseXPath |
getAggregationExpression() |
long |
getCompletionTimeoutMillis() |
SynapseXPath |
getCorrelateExpression() |
String |
getEnclosingElementPropertyName() |
String |
getId() |
Value |
getMaxMessagesToComplete() |
Value |
getMinMessagesToComplete() |
SequenceMediator |
getOnCompleteSequence() |
String |
getOnCompleteSequenceRef() |
void |
init(SynapseEnvironment se)
This method should implement the initialization of the
implemented parts of the configuration.
|
boolean |
isContentAltering()
This is used to indicate whether message payload get modified during mediation
|
boolean |
mediate(MessageContext synCtx)
Aggregate messages flowing through this mediator according to the correlation criteria
and the aggregation algorithm specified to it
|
boolean |
mediate(MessageContext synCtx,
ContinuationState contState)
Mediate the message using a ContinuationState.
|
Integer |
reportOpenStatistics(MessageContext messageContext,
boolean isContentAltering)
Report Open Statistic Event for the Mediator
|
void |
setAggregationExpression(SynapseXPath aggregationExpression) |
void |
setCompletionTimeoutMillis(long completionTimeoutMillis) |
void |
setComponentStatisticsId(ArtifactHolder holder) |
void |
setCorrelateExpression(SynapseXPath correlateExpression) |
void |
setEnclosingElementPropertyName(String enclosingElementPropertyName) |
void |
setId(String id) |
void |
setMaxMessagesToComplete(Value maxMessagesToComplete) |
void |
setMinMessagesToComplete(Value minMessagesToComplete) |
void |
setOnCompleteSequence(SequenceMediator onCompleteSequence) |
void |
setOnCompleteSequenceRef(String onCompleteSequenceRef) |
auditLog, auditWarn, configure, disableStatistics, disableTracing, divertMediationRoute, enableStatistics, enableTracing, getAspectConfiguration, getCommentsList, getDescription, getInputType, getLastSequenceFaultHandler, getLog, getMediatorName, getMediatorPosition, getOutputType, getRegisteredMediationFlowPoint, getShortDescription, getTraceState, getType, handleException, handleException, isBreakPoint, isContentAware, isSkipEnabled, isStatisticsEnable, isTraceOn, isTraceOrDebugOn, isTracingEnabled, registerMediationFlowPoint, reportCloseStatistics, setBreakPoint, setCommentsList, setDescription, setEffectiveTraceState, setMediatorPosition, setShortDescription, setSkipEnabled, setTraceState, shouldCaptureTracing, shouldTrace, shouldTrace, traceOrDebug, traceOrDebugWarn, unregisterMediationFlowPoint
public void init(SynapseEnvironment se)
ManagedLifecycle
init
in interface ManagedLifecycle
se
- SynapseEnvironment to be used for initializationpublic void destroy()
ManagedLifecycle
destroy
in interface ManagedLifecycle
public boolean mediate(MessageContext synCtx)
public boolean mediate(MessageContext synCtx, ContinuationState contState)
FlowContinuableMediator
mediate
in interface FlowContinuableMediator
synCtx
- MessageContextcontState
- ContinuationStatepublic boolean completeAggregate(Aggregate aggregate)
aggregate
- the timed out Aggregate that holds collected messages and propertiespublic SynapseXPath getCorrelateExpression()
public void setCorrelateExpression(SynapseXPath correlateExpression)
public long getCompletionTimeoutMillis()
public void setCompletionTimeoutMillis(long completionTimeoutMillis)
public SynapseXPath getAggregationExpression()
public void setAggregationExpression(SynapseXPath aggregationExpression)
public String getOnCompleteSequenceRef()
public void setOnCompleteSequenceRef(String onCompleteSequenceRef)
public SequenceMediator getOnCompleteSequence()
public void setOnCompleteSequence(SequenceMediator onCompleteSequence)
public Map getActiveAggregates()
public String getId()
public void setId(String id)
public Value getMinMessagesToComplete()
public void setMinMessagesToComplete(Value minMessagesToComplete)
public Value getMaxMessagesToComplete()
public void setMaxMessagesToComplete(Value maxMessagesToComplete)
public String getEnclosingElementPropertyName()
public void setEnclosingElementPropertyName(String enclosingElementPropertyName)
public boolean isContentAltering()
Mediator
isContentAltering
in interface Mediator
isContentAltering
in class AbstractMediator
public Integer reportOpenStatistics(MessageContext messageContext, boolean isContentAltering)
Mediator
reportOpenStatistics
in interface Mediator
reportOpenStatistics
in class AbstractMediator
public void setComponentStatisticsId(ArtifactHolder holder)
setComponentStatisticsId
in interface Mediator
setComponentStatisticsId
in class AbstractMediator
Copyright © 2005–2018 Apache Software Foundation. All rights reserved.