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

Class AbstractAggregatorExecutor

java.lang.Object

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

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:

GroupBasedAggregatorOperationsExecutor, SingleGroupAggregatorExecutor

public abstract class AbstractAggregatorExecutor
extends Object
implements org.mule.runtime.extension.api.runtime.operation.ComponentExecutor<org.mule.runtime.api.meta.model.operation.OperationModel>, org.mule.runtime.api.lifecycle.Lifecycle

Custom abstract executor for aggregator operations.

The reason why we have this custom executor is that unlike regular routers, we should be able to both, have the router 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

Modifier and Type	Field and Description
static String	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
AbstractAggregatorExecutor()

Method Summary

Modifier and Type	Method and Description
void	dispose()
void	initialise()
protected void	injectParameters(Map<String,Object> parameters)
void	start()
void	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

Field Detail

QUORUM_EXCEPTION

public static final String QUORUM_EXCEPTION

See Also:

Constant Field Values

Constructor Detail

AbstractAggregatorExecutor

public AbstractAggregatorExecutor()

Method Detail

injectParameters

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

initialise

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

Specified by:

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

Throws:

org.mule.runtime.api.lifecycle.InitialisationException

start

public void start()
           throws org.mule.runtime.api.exception.MuleException

Specified by:

start in interface org.mule.runtime.api.lifecycle.Startable

Throws:

org.mule.runtime.api.exception.MuleException

stop

public void stop()
          throws org.mule.runtime.api.exception.MuleException

Specified by:

stop in interface org.mule.runtime.api.lifecycle.Stoppable

Throws:

org.mule.runtime.api.exception.MuleException

dispose

public void dispose()

Specified by:

dispose in interface org.mule.runtime.api.lifecycle.Disposable