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()
Map<String,Runnable>	getAvailableAggregators()
org.mule.runtime.api.cluster.ClusterService	getClusterService()
org.mule.runtime.api.component.ConfigurationProperties	getConfigProperties()
AtomicBoolean	getContextStarted()
org.mule.runtime.core.api.context.notification.MuleContextNotificationListener<org.mule.runtime.core.api.context.notification.MuleContextNotification>	getContextStartListener()
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
org.mule.runtime.core.api.lifecycle.PrimaryNodeLifecycleNotificationListener	getNotificationListener()
org.mule.runtime.api.notification.NotificationListenerRegistry	getNotificationListenerRegistry()
Object	getRegisteredAggregatorsModificationLock()
Map<String,AggregatorListener>	getRegisteredListeners()
org.mule.runtime.api.scheduler.Scheduler	getScheduler()
org.mule.runtime.api.scheduler.SchedulerService	getSchedulerService()
long	getTaskSchedulingPeriod()
long	getTaskSchedulingPeriodInMillis() Returns the period used for scheduling registered aggregator tasks in milliseconds.
void	initialise()
boolean	isInitialized()
boolean	isStarted()
void	onContextStarted()
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	setAvailableAggregators(Map<String,Runnable> availableAggregators)
void	setClusterService(org.mule.runtime.api.cluster.ClusterService clusterService)
void	setConfigProperties(org.mule.runtime.api.component.ConfigurationProperties configProperties)
void	setContextStartListener(org.mule.runtime.core.api.context.notification.MuleContextNotificationListener<org.mule.runtime.core.api.context.notification.MuleContextNotification> contextStartListener)
void	setInitialized(boolean initialized)
void	setNotificationListener(org.mule.runtime.core.api.lifecycle.PrimaryNodeLifecycleNotificationListener notificationListener)
void	setNotificationListenerRegistry(org.mule.runtime.api.notification.NotificationListenerRegistry notificationListenerRegistry)
void	setRegisteredListeners(Map<String,AggregatorListener> registeredListeners)
void	setScheduler(org.mule.runtime.api.scheduler.Scheduler scheduler)
void	setSchedulerService(org.mule.runtime.api.scheduler.SchedulerService schedulerService)
void	setStarted(boolean started)
void	setTaskSchedulingPeriod(long taskSchedulingPeriod)
void	start()
void	stop()
void	unregisterListener(String aggregatorName, AggregatorListener listener) Unregisters a listener from an already registered aggregator

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

getRegisteredListeners

public Map<String,AggregatorListener> getRegisteredListeners()

setRegisteredListeners

public void setRegisteredListeners(Map<String,AggregatorListener> registeredListeners)

getAvailableAggregators

public Map<String,Runnable> getAvailableAggregators()

setAvailableAggregators

public void setAvailableAggregators(Map<String,Runnable> availableAggregators)

getRegisteredAggregatorsModificationLock

public Object getRegisteredAggregatorsModificationLock()

isInitialized

public boolean isInitialized()

setInitialized

public void setInitialized(boolean initialized)

isStarted

public boolean isStarted()

setStarted

public void setStarted(boolean started)

getContextStarted

public AtomicBoolean getContextStarted()

getTaskSchedulingPeriod

public long getTaskSchedulingPeriod()

setTaskSchedulingPeriod

public void setTaskSchedulingPeriod(long taskSchedulingPeriod)

getNotificationListener

public org.mule.runtime.core.api.lifecycle.PrimaryNodeLifecycleNotificationListener getNotificationListener()

setNotificationListener

public void setNotificationListener(org.mule.runtime.core.api.lifecycle.PrimaryNodeLifecycleNotificationListener notificationListener)

getContextStartListener

public org.mule.runtime.core.api.context.notification.MuleContextNotificationListener<org.mule.runtime.core.api.context.notification.MuleContextNotification> getContextStartListener()

setContextStartListener

public void setContextStartListener(org.mule.runtime.core.api.context.notification.MuleContextNotificationListener<org.mule.runtime.core.api.context.notification.MuleContextNotification> contextStartListener)

getScheduler

public org.mule.runtime.api.scheduler.Scheduler getScheduler()

setScheduler

public void setScheduler(org.mule.runtime.api.scheduler.Scheduler scheduler)

getSchedulerService

public org.mule.runtime.api.scheduler.SchedulerService getSchedulerService()

setSchedulerService

public void setSchedulerService(org.mule.runtime.api.scheduler.SchedulerService schedulerService)

getNotificationListenerRegistry

public org.mule.runtime.api.notification.NotificationListenerRegistry getNotificationListenerRegistry()

setNotificationListenerRegistry

public void setNotificationListenerRegistry(org.mule.runtime.api.notification.NotificationListenerRegistry notificationListenerRegistry)

getClusterService

public org.mule.runtime.api.cluster.ClusterService getClusterService()

setClusterService

public void setClusterService(org.mule.runtime.api.cluster.ClusterService clusterService)

getConfigProperties

public org.mule.runtime.api.component.ConfigurationProperties getConfigProperties()

setConfigProperties

public void setConfigProperties(org.mule.runtime.api.component.ConfigurationProperties configProperties)

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

onContextStarted

public void onContextStarted()

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

unregisterListener

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

Unregisters a listener from an already registered aggregator

Parameters:

aggregatorName - the name of the aggregator to unregister from

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