org.mule.extension.aggregator.internal.config

Class AggregatorManager

java.lang.Object

org.mule.extension.aggregator.internal.config.AggregatorManager

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

public class AggregatorManager
extends Object
implements org.mule.runtime.api.lifecycle.Lifecycle

Controls the registration of the aggregators and listeners for proper binding between them.

Since:

1.0

Field Summary

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
AggregatorManager()

Method Summary

Modifier and Type	Method and Description
void	dispose()
Optional<AggregatorListener>	getListener(String aggregatorName) 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
long	getTaskSchedulingPeriodInMillis() Returns the period used for scheduling registered aggregator tasks in milliseconds.
void	initialise()
void	registerAggregator(String aggregatorName, Runnable synchronizingTask) Registers a new aggregator to keep track of the available ones and check valid listener registrations.
void	registerListener(String aggregatorName, AggregatorListener listener) Registers a unique listener to an already registered aggregator
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatorManager

public AggregatorManager()

Method Detail

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

registerAggregator

public void registerAggregator(String aggregatorName,
                               Runnable synchronizingTask)

Registers a new aggregator to keep track of the available ones and check valid listener registrations.

Parameters:

aggregatorName - the name of the aggregator registered

registerListener

public void registerListener(String aggregatorName,
                             AggregatorListener listener)
                      throws org.mule.runtime.api.exception.MuleRuntimeException

Registers a unique listener to an already registered aggregator

Parameters:

aggregatorName - the name of the aggregator to register to

listener - the listener to be called when needed

Throws:

org.mule.runtime.api.exception.MuleRuntimeException

getListener

public Optional<AggregatorListener> getListener(String aggregatorName)

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

Returns:

An optional with the listener registered

getTaskSchedulingPeriodInMillis

public long getTaskSchedulingPeriodInMillis()

Returns the period used for scheduling registered aggregator tasks in milliseconds.

Returns:

the configured period in milliseconds