org.mule.extension.aggregator.internal.privileged.executor

Class TimeBasedAggregatorOperationsExecutor

java.lang.Object

org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor

org.mule.extension.aggregator.internal.privileged.executor.SingleGroupAggregatorExecutor

org.mule.extension.aggregator.internal.privileged.executor.TimeBasedAggregatorOperationsExecutor

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Disposable, org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.api.lifecycle.Lifecycle, org.mule.runtime.api.lifecycle.Startable, org.mule.runtime.api.lifecycle.Stoppable, org.mule.runtime.extension.api.runtime.operation.ComponentExecutor<org.mule.runtime.api.meta.model.operation.OperationModel>

public class TimeBasedAggregatorOperationsExecutor
extends SingleGroupAggregatorExecutor

Custom executor for timeBasedAggregator.

Class keeping all the logic for the aggregator defined in TimeBasedAggregatorOperations

The reason why we have this custom executor is that unlike regular routers, we should be able to both, have the it as void (the event out is the same as the event in) and propagate variables in case any is set inside a route.

Since:

1.0

Field Summary

Fields inherited from class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor

QUORUM_EXCEPTION

Fields inherited from interface org.mule.runtime.api.lifecycle.Initialisable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Stoppable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
TimeBasedAggregatorOperationsExecutor(Map<String,Object> params)

Method Summary

Modifier and Type	Method and Description
org.reactivestreams.Publisher<Object>	execute(org.mule.runtime.extension.api.runtime.operation.ExecutionContext<org.mule.runtime.api.meta.model.operation.OperationModel> executionContext)
int	getMaxSize()
void	initialise()
protected void	injectParameters(Map<String,Object> parameters)
void	setMaxSize(int maxSize)

Methods inherited from class org.mule.extension.aggregator.internal.privileged.executor.AbstractAggregatorExecutor

dispose, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeBasedAggregatorOperationsExecutor

public TimeBasedAggregatorOperationsExecutor(Map<String,Object> params)

Method Detail

getMaxSize

public int getMaxSize()

setMaxSize

public void setMaxSize(int maxSize)

execute

public org.reactivestreams.Publisher<Object> execute(org.mule.runtime.extension.api.runtime.operation.ExecutionContext<org.mule.runtime.api.meta.model.operation.OperationModel> executionContext)

injectParameters

protected void injectParameters(Map<String,Object> parameters)

Overrides:

injectParameters in class AbstractAggregatorExecutor

initialise

public void initialise()
                throws org.mule.runtime.api.lifecycle.InitialisationException

Specified by:

initialise in interface org.mule.runtime.api.lifecycle.Initialisable

Overrides:

initialise in class AbstractAggregatorExecutor

Throws:

org.mule.runtime.api.lifecycle.InitialisationException