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() |
Value |
getAggregateElementType() |
SynapsePath |
getAggregationExpression() |
long |
getCompletionTimeoutMillis() |
SynapsePath |
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 |
setAggregateElementType(Value aggregateElementType) |
void |
setAggregationExpression(SynapsePath aggregationExpression) |
void |
setCompletionTimeoutMillis(long completionTimeoutMillis) |
void |
setComponentStatisticsId(ArtifactHolder holder) |
void |
setCorrelateExpression(SynapsePath 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 SynapsePath getCorrelateExpression()
public void setCorrelateExpression(SynapsePath correlateExpression)
public long getCompletionTimeoutMillis()
public void setCompletionTimeoutMillis(long completionTimeoutMillis)
public SynapsePath getAggregationExpression()
public void setAggregationExpression(SynapsePath 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 Value getAggregateElementType()
public void setAggregateElementType(Value aggregateElementType)
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–2024 Apache Software Foundation. All rights reserved.