public class Aggregate
extends java.util.TimerTask
Constructor and Description |
---|
Aggregate(SynapseEnvironment synEnv,
java.lang.String corelation,
long timeoutMillis,
int min,
int max,
AggregateMediator mediator,
FaultHandler faultHandler)
Save aggregation properties and timeout
|
Modifier and Type | Method and Description |
---|---|
boolean |
addMessage(MessageContext synCtx)
Add a message to the interlan message list
|
void |
clear()
Clear references in Aggregate Timer Task
This need to be called when aggregation is completed.
|
java.lang.String |
getCorrelation() |
long |
getExpiryTimeMillis() |
MessageContext |
getLastMessage() |
boolean |
getLock() |
int |
getMaxCount() |
java.util.List<MessageContext> |
getMessages() |
int |
getMinCount() |
long |
getTimeoutMillis() |
boolean |
isComplete(SynapseLog synLog)
Has this aggregation group completed?
|
boolean |
isCompleted() |
void |
releaseLock() |
void |
run() |
void |
setCompleted(boolean completed) |
void |
setCorrelation(java.lang.String correlation) |
void |
setExpiryTimeMillis(long expiryTimeMillis) |
void |
setMaxCount(int maxCount) |
void |
setMessages(java.util.List<MessageContext> messages) |
void |
setMinCount(int minCount) |
void |
setTimeoutMillis(long timeoutMillis) |
public Aggregate(SynapseEnvironment synEnv, java.lang.String corelation, long timeoutMillis, int min, int max, AggregateMediator mediator, FaultHandler faultHandler)
corelation
- representing the corelation name of the messages in the aggregatetimeoutMillis
- the timeout duration in millisecondsmin
- the minimum number of messages to be aggregatedmax
- the maximum number of messages to be aggregatedmediator
- faultHandler
- public boolean addMessage(MessageContext synCtx)
synCtx
- message to be added into this aggregation grouppublic boolean isComplete(SynapseLog synLog)
synLog
- the Synapse log to usepublic MessageContext getLastMessage()
public long getTimeoutMillis()
public void setTimeoutMillis(long timeoutMillis)
public int getMinCount()
public void setMinCount(int minCount)
public int getMaxCount()
public void setMaxCount(int maxCount)
public java.lang.String getCorrelation()
public void setCorrelation(java.lang.String correlation)
public java.util.List<MessageContext> getMessages()
public void setMessages(java.util.List<MessageContext> messages)
public long getExpiryTimeMillis()
public void setExpiryTimeMillis(long expiryTimeMillis)
public void run()
run
in interface java.lang.Runnable
run
in class java.util.TimerTask
public void clear()
public boolean getLock()
public void releaseLock()
public boolean isCompleted()
public void setCompleted(boolean completed)
Copyright © 2005-2021 Apache Software Foundation. All Rights Reserved.