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

Class SingleGroupAggregatorExecutor

java.lang.Object

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

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

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>

Direct Known Subclasses:

SizeBasedAggregatorOperationsExecutor, TimeBasedAggregatorOperationsExecutor

public abstract class SingleGroupAggregatorExecutor
extends AbstractAggregatorExecutor

Custom abstract executor for aggregators with a single aggregation group.

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

BASE_DELAY_MILLIS, MAX_RETRIES, 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
SingleGroupAggregatorExecutor()

Method Summary

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

Methods inherited from interface org.mule.runtime.extension.api.runtime.operation.ComponentExecutor

execute

Constructor Detail

SingleGroupAggregatorExecutor

public SingleGroupAggregatorExecutor()