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

Class SimpleAggregatedContent

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, AggregatedContent

public class SimpleAggregatedContent
extends AbstractAggregatedContent

Stores the aggregated content in memory until completion.

Since:

1.0

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SimpleAggregatedContent(int maxSize)

Method Summary

Modifier and Type	Method and Description
void	add(org.mule.runtime.api.metadata.TypedValue newContent, Long timeStamp) Add a new element to the storage
void	add(org.mule.runtime.api.metadata.TypedValue newContent, Long timeStamp, int sequenceNumber) Add a new element to the storage
List<org.mule.runtime.api.metadata.TypedValue>	getAggregatedElements() Gets the aggregated elements from the storage
boolean	isComplete() Get a boolean indicating if the number of elements is equal to the maximum allowed
boolean	upgradeIfNeeded() Deprecated.

Methods inherited from class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent

getFirstElementArrivalTime, getFirstValueArrivalTime, getLastElementArrivalTime, getLastValueArrivalTime, getMaxSize, isTimedOut, setFirstElementArrivalTime, setLastElementArrivalTime, setMaxSize, setTimedOut, setTimedOut

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleAggregatedContent

public SimpleAggregatedContent(int maxSize)

Method Detail

add

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

Description copied from interface: AggregatedContent

Add a new element to the storage

Specified by:

add in interface AggregatedContent

Specified by:

add in class AbstractAggregatedContent

Parameters:

newContent - the element to be added

timeStamp - the moment when the element was added

add

public void add(org.mule.runtime.api.metadata.TypedValue newContent,
                Long timeStamp,
                int sequenceNumber)

Description copied from interface: AggregatedContent

Add a new element to the storage

Parameters:

newContent - the element to be added

timeStamp - the moment when the element was added

sequenceNumber - the position of the new element inside content being aggregated

getAggregatedElements

public 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

Specified by:

getAggregatedElements in class AbstractAggregatedContent

Returns:

all the elements in the storage

isComplete

public 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

Specified by:

isComplete in class AbstractAggregatedContent

Returns:

true if the group is complete, false otherwise

upgradeIfNeeded

@Deprecated
public boolean upgradeIfNeeded()

Deprecated.

This method upgrades the sequenced elements to the new data structure for backward compatibility.

Returns:

true if the upgrade was made, false otherwise.