Index (Mule Aggregators Module 1.1.2 API)

A C D E G I O Q R S T U V

A

AbstractAggregatedContent - Class in org.mule.extension.aggregator.internal.storage.content
AbstractAggregatedContent() - Constructor for class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
AbstractAggregatorExecutor - Class in org.mule.extension.aggregator.internal.privileged.executor: Custom abstract executor for aggregator operations.
AbstractAggregatorExecutor() - Constructor for class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor
AbstractAggregatorOperations - Class in org.mule.extension.aggregator.internal.operations
AbstractAggregatorOperations() - Constructor for class org.mule.extension.aggregator.internal.operations.AbstractAggregatorOperations
add(TypedValue, Long) - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
add(TypedValue, Long) - Method in interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent: Add a new element to the storage
add(TypedValue, Long, int) - Method in interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent: Add a new element to the storage
add(TypedValue, Long) - Method in class org.mule.extension.aggregator.internal.storage.content.SimpleAggregatedContent
add(TypedValue, Long, int) - Method in class org.mule.extension.aggregator.internal.storage.content.SimpleAggregatedContent
aggregateByGroup(GroupBasedAggregatorParameterGroup, IncrementalAggregationRoute, AggregationCompleteRoute, RouterCompletionCallback) - Method in class org.mule.extension.aggregator.internal.operations.GroupBasedAggregatorOperations: Aggregates a new event to the group and executes the routes and listeners if it corresponds.
aggregateBySize(SizeBasedAggregatorParameterGroup, IncrementalAggregationRoute, AggregationCompleteRoute, RouterCompletionCallback) - Method in class org.mule.extension.aggregator.internal.operations.SizeBasedAggregatorOperations: Aggregates a new event and executes the routes and listeners if it corresponds.
aggregateByTime(TimeBasedAggregatorParameterGroup, IncrementalAggregationRoute, RouterCompletionCallback) - Method in class org.mule.extension.aggregator.internal.operations.TimeBasedAggregatorOperations: This aggregator aggregates elements until it reaches the specified time period.
AggregatedContent - Interface in org.mule.extension.aggregator.internal.storage.content
AggregationAttributes - Class in org.mule.extension.aggregator.api: Attributes with information regarding the containing aggregator and the aggregated elements
AggregationAttributes() - Constructor for class org.mule.extension.aggregator.api.AggregationAttributes
AggregationAttributes(String, long, long, boolean) - Constructor for class org.mule.extension.aggregator.api.AggregationAttributes
AggregationChainInputResolver - Class in org.mule.extension.aggregator.internal.resolver: A ChainInputTypeResolver which wraps the payload type into an array of the same type.
AggregationChainInputResolver() - Constructor for class org.mule.extension.aggregator.internal.resolver.AggregationChainInputResolver
AggregationCompleteRoute - Class in org.mule.extension.aggregator.internal.routes: Route to execute when group aggregation is completed.
AggregationCompleteRoute() - Constructor for class org.mule.extension.aggregator.internal.routes.AggregationCompleteRoute
AggregatorConstants - Class in org.mule.extension.aggregator.api: Information related to aggregators
AggregatorConstants() - Constructor for class org.mule.extension.aggregator.api.AggregatorConstants
AggregatorError - Enum in org.mule.extension.aggregator.internal.errors: Errors for Aggregators
AggregatorErrorProvider - Class in org.mule.extension.aggregator.internal.errors
AggregatorErrorProvider() - Constructor for class org.mule.extension.aggregator.internal.errors.AggregatorErrorProvider
AggregatorListener - Class in org.mule.extension.aggregator.internal.source: Source for listening to events triggered by aggregator
AggregatorListener() - Constructor for class org.mule.extension.aggregator.internal.source.AggregatorListener
AggregatorManager - Class in org.mule.extension.aggregator.internal.config: Controls the registration of the aggregators and listeners for proper binding between them.
AggregatorManager() - Constructor for class org.mule.extension.aggregator.internal.config.AggregatorManager
AggregatorParameterGroup - Class in org.mule.extension.aggregator.internal.parameter: Common aggregator parameters
AggregatorParameterGroup() - Constructor for class org.mule.extension.aggregator.internal.parameter.AggregatorParameterGroup
AggregatorsExtension - Class in org.mule.extension.aggregator.internal
AggregatorsExtension() - Constructor for class org.mule.extension.aggregator.internal.AggregatorsExtension
AggregatorSharedInformation - Interface in org.mule.extension.aggregator.internal.storage.info
AggregatorStereotype - Class in org.mule.extension.aggregator.api.stereotype: StereotypeDefinition for a generic AbstractAggregatorOperations.
AggregatorStereotype() - Constructor for class org.mule.extension.aggregator.api.stereotype.AggregatorStereotype
AsyncTask - Interface in org.mule.extension.aggregator.internal.task: POJO to store information about tasks to be scheduled

C

CompletionCallbackWrapper - Class in org.mule.extension.aggregator.internal.privileged: Callback called when an aggregation execution is complete.
CompletionCallbackWrapper(CompletionCallback, CoreEvent) - Constructor for class org.mule.extension.aggregator.internal.privileged.CompletionCallbackWrapper

D

dispose() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
dispose() - Method in class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor

E

enrich(ExtensionLoadingContext) - Method in class org.mule.extension.aggregator.internal.privileged.enricher.GroupBasedAggregatorOperationsEnricher
enrich(ExtensionLoadingContext) - Method in class org.mule.extension.aggregator.internal.privileged.enricher.SizeBasedAggregatorOperationsEnricher
enrich(ExtensionLoadingContext) - Method in class org.mule.extension.aggregator.internal.privileged.enricher.TimeBasedAggregatorOperationsEnricher
error(Throwable) - Method in class org.mule.extension.aggregator.internal.privileged.CompletionCallbackWrapper
execute(ExecutionContext<OperationModel>) - Method in class org.mule.extension.aggregator.internal.privileged.executor.GroupBasedAggregatorOperationsExecutor
execute(ExecutionContext<OperationModel>) - Method in class org.mule.extension.aggregator.internal.privileged.executor.SizeBasedAggregatorOperationsExecutor
execute(ExecutionContext<OperationModel>) - Method in class org.mule.extension.aggregator.internal.privileged.executor.TimeBasedAggregatorOperationsExecutor

G

getAggregatedContent(String) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
getAggregatedContent() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
getAggregatedElements() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
getAggregatedElements() - Method in interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent: Gets the aggregated elements from the storage
getAggregatedElements() - Method in class org.mule.extension.aggregator.internal.storage.content.SimpleAggregatedContent
getAggregationId() - Method in class org.mule.extension.aggregator.api.AggregationAttributes
getAggregationId() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
getAggregatorName() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
getAsyncAggregationTask() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
getAvailableAggregators() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getCallback() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
getCategoryName() - Method in class org.mule.extension.aggregator.internal.resolver.AggregationChainInputResolver
getChainInputMetadataType(ChainInputMetadataContext) - Method in class org.mule.extension.aggregator.internal.resolver.AggregationChainInputResolver
getClusterService() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getConfigProperties() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getContent() - Method in class org.mule.extension.aggregator.internal.parameter.AggregatorParameterGroup
getContent() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
getContentMap() - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
getContextStarted() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getContextStartListener() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getDelay() - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask: Returns the time to wait until executing this task
getDelay() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
getDelayTimeUnit() - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask: Returns the time unit of the delay time
getDelayTimeUnit() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
getDelayUnit() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
getDelegate() - Method in class org.mule.extension.aggregator.internal.privileged.CompletionCallbackWrapper
getErrorTypes() - Method in class org.mule.extension.aggregator.internal.errors.AggregatorErrorProvider
getErrorTypes() - Method in class org.mule.extension.aggregator.internal.errors.GroupBasedAggregatorErrorProvider
getEvent() - Method in class org.mule.extension.aggregator.internal.privileged.CompletionCallbackWrapper
getEvictionTime() - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
getEvictionTimeUnit() - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
getFirstElementArrivalTime() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
getFirstItemArrivalTime() - Method in class org.mule.extension.aggregator.api.AggregationAttributes
getFirstValueArrivalTime() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent: Deprecated.
getFirstValueArrivalTime() - Method in interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent: Get a timestamp representing when the first value was aggregated
getGroupId() - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
getGroupSize() - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
getId() - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask: return the task id
getId() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
getIsAggregationComplete() - Method in class org.mule.extension.aggregator.api.AggregationAttributes
getLastConfiguredEvictionTime() - Method in class org.mule.extension.aggregator.internal.privileged.executor.GroupBasedAggregatorOperationsExecutor
getLastConfiguredEvictionTimeUnit() - Method in class org.mule.extension.aggregator.internal.privileged.executor.GroupBasedAggregatorOperationsExecutor
getLastElementArrivalTime() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
getLastItemArrivalTime() - Method in class org.mule.extension.aggregator.api.AggregationAttributes
getLastValueArrivalTime() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent: Deprecated.
getLastValueArrivalTime() - Method in interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent: Get a timestamp with the time of the last aggregated element
getListener(String) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager: Get the listener registered to the aggregator with
If the aggregator does not have any listener registered to it an Optional.empty() will be returned
getManager() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
getMaxSize() - Method in class org.mule.extension.aggregator.internal.privileged.executor.SizeBasedAggregatorOperationsExecutor
getMaxSize() - Method in class org.mule.extension.aggregator.internal.privileged.executor.TimeBasedAggregatorOperationsExecutor
getMaxSize() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
getName() - Method in class org.mule.extension.aggregator.api.stereotype.AggregatorStereotype
getNotificationListener() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getNotificationListenerRegistry() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getParent() - Method in class org.mule.extension.aggregator.api.stereotype.AggregatorStereotype
getParent() - Method in enum org.mule.extension.aggregator.internal.errors.AggregatorError
getPeriod() - Method in class org.mule.extension.aggregator.internal.parameter.TimeBasedAggregatorParameterGroup
getPeriodUnit() - Method in class org.mule.extension.aggregator.internal.parameter.TimeBasedAggregatorParameterGroup
getRegisteredAggregatorsModificationLock() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getRegisteredAsyncAggregationTask() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
getRegisteredEvictions() - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
getRegisteredGroupEvictionTasks() - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
getRegisteredListeners() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getRegisteredTimeoutAsyncAggregations() - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
getRegisteredTimeouts() - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
getRegisteringTimestamp() - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask
getRegisteringTimestamp() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
getResolverName() - Method in class org.mule.extension.aggregator.internal.resolver.AggregationChainInputResolver
getScheduler() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getSchedulerService() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getSourceCallback() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
getStarted() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
getStartLock() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
getTaskSchedulingPeriod() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
getTaskSchedulingPeriodInMillis() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager: Returns the period used for scheduling registered aggregator tasks in milliseconds.
getTimeout() - Method in class org.mule.extension.aggregator.internal.parameter.TimeoutContainingAggregatorParameterGroup
getTimeoutUnit() - Method in class org.mule.extension.aggregator.internal.parameter.TimeoutContainingAggregatorParameterGroup
GroupAggregatorSharedInformation - Class in org.mule.extension.aggregator.internal.storage.info
GroupAggregatorSharedInformation() - Constructor for class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
GroupBasedAggregatorErrorProvider - Class in org.mule.extension.aggregator.internal.errors: Declares errors thrown by GroupBasedAggregatorOperations
GroupBasedAggregatorErrorProvider() - Constructor for class org.mule.extension.aggregator.internal.errors.GroupBasedAggregatorErrorProvider
GroupBasedAggregatorOperations - Class in org.mule.extension.aggregator.internal.operations: Operations defined for a Group Based aggregator.
GroupBasedAggregatorOperations() - Constructor for class org.mule.extension.aggregator.internal.operations.GroupBasedAggregatorOperations
GroupBasedAggregatorOperationsEnricher - Class in org.mule.extension.aggregator.internal.privileged.enricher: Sets GroupBasedAggregatorOperationsExecutor as the executor of the groupBasedAggregator operation
GroupBasedAggregatorOperationsEnricher() - Constructor for class org.mule.extension.aggregator.internal.privileged.enricher.GroupBasedAggregatorOperationsEnricher
GroupBasedAggregatorOperationsExecutor - Class in org.mule.extension.aggregator.internal.privileged.executor: Custom executor for groupBasedAggregator.
GroupBasedAggregatorOperationsExecutor(Map<String, Object>) - Constructor for class org.mule.extension.aggregator.internal.privileged.executor.GroupBasedAggregatorOperationsExecutor
GroupBasedAggregatorParameterGroup - Class in org.mule.extension.aggregator.internal.parameter: Parameters used to configure aggregators by group
GroupBasedAggregatorParameterGroup() - Constructor for class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup

I

IncrementalAggregationRoute - Class in org.mule.extension.aggregator.internal.routes: Aggregation route to be executed whenever a new event arrives to the aggregator but the condition for the group to be complete is not yet met.
IncrementalAggregationRoute() - Constructor for class org.mule.extension.aggregator.internal.routes.IncrementalAggregationRoute
initialise() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
initialise() - Method in class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor
initialise() - Method in class org.mule.extension.aggregator.internal.privileged.executor.SizeBasedAggregatorOperationsExecutor
initialise() - Method in class org.mule.extension.aggregator.internal.privileged.executor.TimeBasedAggregatorOperationsExecutor
injectParameters(Map<String, Object>) - Method in class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor
injectParameters(Map<String, Object>) - Method in class org.mule.extension.aggregator.internal.privileged.executor.SizeBasedAggregatorOperationsExecutor
injectParameters(Map<String, Object>) - Method in class org.mule.extension.aggregator.internal.privileged.executor.TimeBasedAggregatorOperationsExecutor
isAggregationComplete() - Method in class org.mule.extension.aggregator.api.AggregationAttributes
isComplete() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
isComplete() - Method in interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent: Get a boolean indicating if the number of elements is equal to the maximum allowed
isComplete() - Method in class org.mule.extension.aggregator.internal.storage.content.SimpleAggregatedContent
isIncludeTimedOutGroups() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
isInitialized() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
isScheduled() - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask: Returns true if the task was already scheduled.
isScheduled() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
isStarted() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
isStarted() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
isTimedOut() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
isTimeoutSet() - Method in class org.mule.extension.aggregator.internal.parameter.TimeoutContainingAggregatorParameterGroup

O

onContextStarted() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
onStart(SourceCallback<Message, AggregationAttributes>) - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
onStop() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
OPERATION_NAME - Static variable in class org.mule.extension.aggregator.internal.privileged.enricher.SizeBasedAggregatorOperationsEnricher
OPERATION_NAME - Static variable in class org.mule.extension.aggregator.internal.privileged.enricher.TimeBasedAggregatorOperationsEnricher
org.mule.extension.aggregator.api - package org.mule.extension.aggregator.api
org.mule.extension.aggregator.api.stereotype - package org.mule.extension.aggregator.api.stereotype
org.mule.extension.aggregator.internal - package org.mule.extension.aggregator.internal
org.mule.extension.aggregator.internal.config - package org.mule.extension.aggregator.internal.config
org.mule.extension.aggregator.internal.errors - package org.mule.extension.aggregator.internal.errors
org.mule.extension.aggregator.internal.operations - package org.mule.extension.aggregator.internal.operations
org.mule.extension.aggregator.internal.parameter - package org.mule.extension.aggregator.internal.parameter
org.mule.extension.aggregator.internal.privileged - package org.mule.extension.aggregator.internal.privileged
org.mule.extension.aggregator.internal.privileged.enricher - package org.mule.extension.aggregator.internal.privileged.enricher
org.mule.extension.aggregator.internal.privileged.executor - package org.mule.extension.aggregator.internal.privileged.executor
org.mule.extension.aggregator.internal.resolver - package org.mule.extension.aggregator.internal.resolver
org.mule.extension.aggregator.internal.routes - package org.mule.extension.aggregator.internal.routes
org.mule.extension.aggregator.internal.source - package org.mule.extension.aggregator.internal.source
org.mule.extension.aggregator.internal.storage.content - package org.mule.extension.aggregator.internal.storage.content
org.mule.extension.aggregator.internal.storage.info - package org.mule.extension.aggregator.internal.storage.info
org.mule.extension.aggregator.internal.task - package org.mule.extension.aggregator.internal.task

Q

QUORUM_EXCEPTION - Static variable in class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor

R

registerAggregator(String, Runnable) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager: Registers a new aggregator to keep track of the available ones and check valid listener registrations.
registerAsyncAggregationTask(AsyncTask) - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
registerGroupEvictionTask(String, AsyncTask) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
registerListener(String, AggregatorListener) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager: Registers a unique listener to an already registered aggregator
registerTimeoutAsyncAggregation(String, AsyncTask) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
removeAggregatedContent(String) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation

S

setAggregatedContent(String, AggregatedContent) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
setAggregatedContent(AggregatedContent) - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
setAggregationComplete() - Method in class org.mule.extension.aggregator.api.AggregationAttributes
setAggregationComplete(boolean) - Method in class org.mule.extension.aggregator.api.AggregationAttributes
setAggregationId(String) - Method in class org.mule.extension.aggregator.api.AggregationAttributes
setAggregationId(String) - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
setAggregatorName(String) - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
setAsyncAggregationTask(AsyncTask) - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
setAvailableAggregators(Map<String, Runnable>) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setClusterService(ClusterService) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setConfigProperties(ConfigurationProperties) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setContent(TypedValue) - Method in class org.mule.extension.aggregator.internal.parameter.AggregatorParameterGroup
setContent(AggregatedContent) - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
setContentMap(Map<String, AggregatedContent>) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
setContextStartListener(MuleContextNotificationListener<MuleContextNotification>) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setDelay(int) - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
setDelayUnit(TimeUnit) - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
setDelegate(CompletionCallback) - Method in class org.mule.extension.aggregator.internal.privileged.CompletionCallbackWrapper
setEvent(CoreEvent) - Method in class org.mule.extension.aggregator.internal.privileged.CompletionCallbackWrapper
setEvictionTime(Integer) - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
setEvictionTime(int) - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
setEvictionTimeUnit(TimeUnit) - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
setFirstElementArrivalTime(Long) - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
setFirstItemArrivalTime(long) - Method in class org.mule.extension.aggregator.api.AggregationAttributes
setGroupId(String) - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
setGroupSize(Integer) - Method in class org.mule.extension.aggregator.internal.parameter.GroupBasedAggregatorParameterGroup
setId(String) - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
setIncludeTimedOutGroups(boolean) - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
setInitialized(boolean) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setLastConfiguredEvictionTime(int) - Method in class org.mule.extension.aggregator.internal.privileged.executor.GroupBasedAggregatorOperationsExecutor
setLastConfiguredEvictionTimeUnit(TimeUnit) - Method in class org.mule.extension.aggregator.internal.privileged.executor.GroupBasedAggregatorOperationsExecutor
setLastElementArrivalTime(Long) - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
setLastItemArrivalTime(long) - Method in class org.mule.extension.aggregator.api.AggregationAttributes
setManager(AggregatorManager) - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
setMaxSize(int) - Method in class org.mule.extension.aggregator.internal.privileged.executor.SizeBasedAggregatorOperationsExecutor
setMaxSize(int) - Method in class org.mule.extension.aggregator.internal.privileged.executor.TimeBasedAggregatorOperationsExecutor
setMaxSize(int) - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
setNotificationListener(PrimaryNodeLifecycleNotificationListener) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setNotificationListenerRegistry(NotificationListenerRegistry) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setPeriod(Integer) - Method in class org.mule.extension.aggregator.internal.parameter.TimeBasedAggregatorParameterGroup
setPeriod(int) - Method in class org.mule.extension.aggregator.internal.parameter.TimeBasedAggregatorParameterGroup
setPeriodUnit(TimeUnit) - Method in class org.mule.extension.aggregator.internal.parameter.TimeBasedAggregatorParameterGroup
setRegistered(long) - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask: Sets the task as registered
setRegistered(long) - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
setRegisteredEvictions(Map<String, AsyncTask>) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
setRegisteredListeners(Map<String, AggregatorListener>) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setRegisteredTimeouts(Map<String, AsyncTask>) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
setRegisteringTimestamp(long) - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
setScheduled() - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask: Sets the task as scheduled
setScheduled() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
setScheduled(boolean) - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
setScheduler(Scheduler) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setSchedulerService(SchedulerService) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setSourceCallback(SourceCallback<Message, AggregationAttributes>) - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
setStarted(boolean) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setStarted(Boolean) - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
setTaskSchedulingPeriod(long) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
setTimedOut() - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent: Deprecated.
setTimedOut(boolean) - Method in class org.mule.extension.aggregator.internal.storage.content.AbstractAggregatedContent
setTimeout(Integer) - Method in class org.mule.extension.aggregator.internal.parameter.TimeoutContainingAggregatorParameterGroup
setTimeout(int) - Method in class org.mule.extension.aggregator.internal.parameter.TimeoutContainingAggregatorParameterGroup
setTimeoutUnit(TimeUnit) - Method in class org.mule.extension.aggregator.internal.parameter.TimeoutContainingAggregatorParameterGroup
setUnscheduled() - Method in interface org.mule.extension.aggregator.internal.task.AsyncTask: Sets the task as not scheduled
setUnscheduled() - Method in class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
shouldIncludeTimedOutGroups() - Method in class org.mule.extension.aggregator.internal.source.AggregatorListener
shouldRegisterEviction(String) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
shouldRegisterNextAsyncAggregation() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
shouldRegisterTimeout(String) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
SimpleAggregatedContent - Class in org.mule.extension.aggregator.internal.storage.content: Stores the aggregated content in memory until completion.
SimpleAggregatedContent(int) - Constructor for class org.mule.extension.aggregator.internal.storage.content.SimpleAggregatedContent
SimpleAggregatorSharedInformation - Class in org.mule.extension.aggregator.internal.storage.info
SimpleAggregatorSharedInformation() - Constructor for class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
SimpleAsyncTask - Class in org.mule.extension.aggregator.internal.task
SimpleAsyncTask(int, TimeUnit) - Constructor for class org.mule.extension.aggregator.internal.task.SimpleAsyncTask
SingleGroupAggregatorExecutor - Class in org.mule.extension.aggregator.internal.privileged.executor: Custom abstract executor for aggregators with a single aggregation group.
SingleGroupAggregatorExecutor() - Constructor for class org.mule.extension.aggregator.internal.privileged.executor.SingleGroupAggregatorExecutor
SingleGroupAggregatorOperations - Class in org.mule.extension.aggregator.internal.operations: Aggregator Operations for aggregators with only 1 group at a time.
SingleGroupAggregatorOperations() - Constructor for class org.mule.extension.aggregator.internal.operations.SingleGroupAggregatorOperations
SizeBasedAggregatorOperations - Class in org.mule.extension.aggregator.internal.operations: Operations defined for a Size Based Aggregator.
SizeBasedAggregatorOperations() - Constructor for class org.mule.extension.aggregator.internal.operations.SizeBasedAggregatorOperations
SizeBasedAggregatorOperationsEnricher - Class in org.mule.extension.aggregator.internal.privileged.enricher: Sets SizeBasedAggregatorOperationsExecutor as the executor of the sizeBasedAggregator operation
SizeBasedAggregatorOperationsEnricher() - Constructor for class org.mule.extension.aggregator.internal.privileged.enricher.SizeBasedAggregatorOperationsEnricher
SizeBasedAggregatorOperationsExecutor - Class in org.mule.extension.aggregator.internal.privileged.executor: Custom executor for sizeBasedAggregator.
SizeBasedAggregatorOperationsExecutor(Map<String, Object>) - Constructor for class org.mule.extension.aggregator.internal.privileged.executor.SizeBasedAggregatorOperationsExecutor
SizeBasedAggregatorParameterGroup - Class in org.mule.extension.aggregator.internal.parameter: Parameters used to configure aggregators by size.
SizeBasedAggregatorParameterGroup() - Constructor for class org.mule.extension.aggregator.internal.parameter.SizeBasedAggregatorParameterGroup
start() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
start() - Method in class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor
stop() - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager
stop() - Method in class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor
success(Result<Object, Object>) - Method in class org.mule.extension.aggregator.internal.privileged.CompletionCallbackWrapper

T

TASK_SCHEDULING_PERIOD_KEY - Static variable in class org.mule.extension.aggregator.api.AggregatorConstants
TASK_SCHEDULING_PERIOD_SYSTEM_PROPERTY_KEY - Static variable in class org.mule.extension.aggregator.api.AggregatorConstants
TimeBasedAggregatorOperations - Class in org.mule.extension.aggregator.internal.operations
TimeBasedAggregatorOperations() - Constructor for class org.mule.extension.aggregator.internal.operations.TimeBasedAggregatorOperations
TimeBasedAggregatorOperationsEnricher - Class in org.mule.extension.aggregator.internal.privileged.enricher: Sets TimeBasedAggregatorOperationsExecutor as the executor of the timeBasedAggregator operation
TimeBasedAggregatorOperationsEnricher() - Constructor for class org.mule.extension.aggregator.internal.privileged.enricher.TimeBasedAggregatorOperationsEnricher
TimeBasedAggregatorOperationsExecutor - Class in org.mule.extension.aggregator.internal.privileged.executor: Custom executor for timeBasedAggregator.
TimeBasedAggregatorOperationsExecutor(Map<String, Object>) - Constructor for class org.mule.extension.aggregator.internal.privileged.executor.TimeBasedAggregatorOperationsExecutor
TimeBasedAggregatorParameterGroup - Class in org.mule.extension.aggregator.internal.parameter: Parameters used to configure aggregators by time.
TimeBasedAggregatorParameterGroup() - Constructor for class org.mule.extension.aggregator.internal.parameter.TimeBasedAggregatorParameterGroup
TimeoutContainingAggregatorParameterGroup - Class in org.mule.extension.aggregator.internal.parameter: Extends AggregatorParameterGroup adding timeout parameter
TimeoutContainingAggregatorParameterGroup() - Constructor for class org.mule.extension.aggregator.internal.parameter.TimeoutContainingAggregatorParameterGroup

U

unregisterAsyncAggregationTask() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation
unregisterGroupEvictionTask(String) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
unregisterListener(String, AggregatorListener) - Method in class org.mule.extension.aggregator.internal.config.AggregatorManager: Unregisters a listener from an already registered aggregator
unregisterTimeoutAsyncAggregation(String) - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation
upgradeIfNeeded() - Method in interface org.mule.extension.aggregator.internal.storage.content.AggregatedContent: Deprecated.
upgradeIfNeeded() - Method in class org.mule.extension.aggregator.internal.storage.content.SimpleAggregatedContent: Deprecated.
upgradeIfNeeded() - Method in interface org.mule.extension.aggregator.internal.storage.info.AggregatorSharedInformation: Deprecated.
upgradeIfNeeded() - Method in class org.mule.extension.aggregator.internal.storage.info.GroupAggregatorSharedInformation: Deprecated.
upgradeIfNeeded() - Method in class org.mule.extension.aggregator.internal.storage.info.SimpleAggregatorSharedInformation: Deprecated.

V

valueOf(String) - Static method in enum org.mule.extension.aggregator.internal.errors.AggregatorError: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.mule.extension.aggregator.internal.errors.AggregatorError: Returns an array containing the constants of this enum type, in the order they are declared.

A C D E G I O Q R S T U V