org.mule.extension.aggregator.internal.storage.content

Class AbstractAggregatedContent

java.lang.Object

org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent

All Implemented Interfaces:

Serializable, AggregatedContent

Direct Known Subclasses:

SimpleAggregatedContent

public abstract class AbstractAggregatedContent
extends Object
implements AggregatedContent

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
AbstractAggregatedContent()

Method Summary

Modifier and Type	Method and Description
abstract void	add(org.mule.runtime.api.metadata.TypedValue newElement, Long timeStamp) Add a new element to the storage
abstract List<org.mule.runtime.api.metadata.TypedValue>	getAggregatedElements() Gets the aggregated elements from the storage
Long	getFirstValueArrivalTime() Get a timestamp representing when the first value was aggregated
Long	getLastValueArrivalTime() Get a timestamp with the time of the last aggregated element
int	getMaxSize()
abstract boolean	isComplete() Get a boolean indicating if the number of elements is equal to the maximum allowed
boolean	isTimedOut()
void	setMaxSize(int maxSize)
void	setTimedOut()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent

add

Constructor Detail

AbstractAggregatedContent

public AbstractAggregatedContent()

Method Detail

isComplete

public abstract boolean isComplete()

Description copied from interface: AggregatedContent

Get a boolean indicating if the number of elements is equal to the maximum allowed

Specified by:

isComplete in interface AggregatedContent

Returns:

true if the group is complete, false otherwise

add

public abstract void add(org.mule.runtime.api.metadata.TypedValue newElement,
                         Long timeStamp)

Description copied from interface: AggregatedContent

Add a new element to the storage

Specified by:

add in interface AggregatedContent

Parameters:

newElement - the element to be added

timeStamp - the moment when the element was added

getAggregatedElements

public abstract List<org.mule.runtime.api.metadata.TypedValue> getAggregatedElements()

Description copied from interface: AggregatedContent

Gets the aggregated elements from the storage

Specified by:

getAggregatedElements in interface AggregatedContent

Returns:

all the elements in the storage

getMaxSize

public int getMaxSize()

setMaxSize

public void setMaxSize(int maxSize)

isTimedOut

public boolean isTimedOut()

setTimedOut

public void setTimedOut()

getFirstValueArrivalTime

public Long getFirstValueArrivalTime()

Description copied from interface: AggregatedContent

Get a timestamp representing when the first value was aggregated

Specified by:

getFirstValueArrivalTime in interface AggregatedContent

Returns:

a timestamp with the time of the first aggregated value

getLastValueArrivalTime

public Long getLastValueArrivalTime()

Description copied from interface: AggregatedContent

Get a timestamp with the time of the last aggregated element

Specified by:

getLastValueArrivalTime in interface AggregatedContent

Returns:

a timestamp with the time of the last aggregated element