org.mule.extension.aggregator.internal.storage.info

Class GroupAggregatorSharedInformation

java.lang.Object

org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation

All Implemented Interfaces:

Serializable, AggregatorSharedInformation

public class GroupAggregatorSharedInformation
extends Object
implements AggregatorSharedInformation

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GroupAggregatorSharedInformation()

Method Summary

Modifier and Type	Method and Description
AggregatedContent	getAggregatedContent(String groupId)
Map<String,AggregatedContent>	getContentMap()
Map<String,AsyncTask>	getRegisteredEvictions()
Map<String,AsyncTask>	getRegisteredGroupEvictionTasks()
Map<String,AsyncTask>	getRegisteredTimeoutAsyncAggregations()
Map<String,AsyncTask>	getRegisteredTimeouts()
void	registerGroupEvictionTask(String groupId, AsyncTask groupEvictionTask)
void	registerTimeoutAsyncAggregation(String groupId, AsyncTask timeoutTask)
void	removeAggregatedContent(String groupId)
void	setAggregatedContent(String groupId, AggregatedContent content)
void	setContentMap(Map<String,AggregatedContent> contentMap)
void	setRegisteredEvictions(Map<String,AsyncTask> registeredEvictions)
void	setRegisteredTimeouts(Map<String,AsyncTask> registeredTimeouts)
boolean	shouldRegisterEviction(String groupId)
boolean	shouldRegisterTimeout(String groupId)
void	unregisterGroupEvictionTask(String groupId)
void	unregisterTimeoutAsyncAggregation(String groupId)
boolean	upgradeIfNeeded() Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupAggregatorSharedInformation

public GroupAggregatorSharedInformation()

Method Detail

getAggregatedContent

public AggregatedContent getAggregatedContent(String groupId)

setAggregatedContent

public void setAggregatedContent(String groupId,
                                 AggregatedContent content)

removeAggregatedContent

public void removeAggregatedContent(String groupId)

shouldRegisterEviction

public boolean shouldRegisterEviction(String groupId)

registerGroupEvictionTask

public void registerGroupEvictionTask(String groupId,
                                      AsyncTask groupEvictionTask)

unregisterGroupEvictionTask

public void unregisterGroupEvictionTask(String groupId)

getRegisteredGroupEvictionTasks

public Map<String,AsyncTask> getRegisteredGroupEvictionTasks()

shouldRegisterTimeout

public boolean shouldRegisterTimeout(String groupId)

registerTimeoutAsyncAggregation

public void registerTimeoutAsyncAggregation(String groupId,
                                            AsyncTask timeoutTask)

unregisterTimeoutAsyncAggregation

public void unregisterTimeoutAsyncAggregation(String groupId)

getRegisteredTimeoutAsyncAggregations

public Map<String,AsyncTask> getRegisteredTimeoutAsyncAggregations()

upgradeIfNeeded

@Deprecated
public boolean upgradeIfNeeded()

Deprecated.

This method upgrades the sequenced elements to the new data structure for backward compatibility. It is not necessary to do an upgrade for this class.

Specified by:

upgradeIfNeeded in interface AggregatorSharedInformation

Returns:

true if any upgrade was made, false otherwise.

getContentMap

public Map<String,AggregatedContent> getContentMap()

setContentMap

public void setContentMap(Map<String,AggregatedContent> contentMap)

getRegisteredEvictions

public Map<String,AsyncTask> getRegisteredEvictions()

setRegisteredEvictions

public void setRegisteredEvictions(Map<String,AsyncTask> registeredEvictions)

getRegisteredTimeouts

public Map<String,AsyncTask> getRegisteredTimeouts()

setRegisteredTimeouts

public void setRegisteredTimeouts(Map<String,AsyncTask> registeredTimeouts)