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

Class GroupBasedAggregatorOperationsExecutor

java.lang.Object

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

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

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 GroupBasedAggregatorOperationsExecutor
extends AbstractAggregatorExecutor

Custom executor for groupBasedAggregator.

Class keeping all the logic for the aggregator defined in GroupBasedAggregatorOperations

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
GroupBasedAggregatorOperationsExecutor(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	getLastConfiguredEvictionTime()
TimeUnit	getLastConfiguredEvictionTimeUnit()
void	setLastConfiguredEvictionTime(int lastConfiguredEvictionTime)
void	setLastConfiguredEvictionTimeUnit(TimeUnit lastConfiguredEvictionTimeUnit)

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

dispose, initialise, injectParameters, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupBasedAggregatorOperationsExecutor

public GroupBasedAggregatorOperationsExecutor(Map<String,Object> params)

Method Detail

getLastConfiguredEvictionTime

public int getLastConfiguredEvictionTime()

setLastConfiguredEvictionTime

public void setLastConfiguredEvictionTime(int lastConfiguredEvictionTime)

getLastConfiguredEvictionTimeUnit

public TimeUnit getLastConfiguredEvictionTimeUnit()

setLastConfiguredEvictionTimeUnit

public void setLastConfiguredEvictionTimeUnit(TimeUnit lastConfiguredEvictionTimeUnit)

execute

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