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	getFirstElementArrivalTime()
Long	getFirstValueArrivalTime() Deprecated.
Long	getLastElementArrivalTime()
Long	getLastValueArrivalTime() Deprecated.
int	getMaxSize()
abstract boolean	isComplete() Get a boolean indicating if the number of elements is equal to the maximum allowed
boolean	isTimedOut()
void	setFirstElementArrivalTime(Long firstElementArrivalTime)
void	setLastElementArrivalTime(Long lastElementArrivalTime)
void	setMaxSize(int maxSize)
void	setTimedOut() Deprecated.
void	setTimedOut(boolean timedOut)

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, upgradeIfNeeded

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

@Deprecated
public void setTimedOut()

Deprecated.

getFirstValueArrivalTime

@Deprecated
public Long getFirstValueArrivalTime()

Deprecated.

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

@Deprecated
public Long getLastValueArrivalTime()

Deprecated.

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

setTimedOut

public void setTimedOut(boolean timedOut)

getFirstElementArrivalTime

public Long getFirstElementArrivalTime()

setFirstElementArrivalTime

public void setFirstElementArrivalTime(Long firstElementArrivalTime)

getLastElementArrivalTime

public Long getLastElementArrivalTime()

setLastElementArrivalTime

public void setLastElementArrivalTime(Long lastElementArrivalTime)