org.mule.extension.aggregator.internal.source

Class AggregatorListener

java.lang.Object

org.mule.runtime.extension.api.runtime.source.Source<org.mule.runtime.api.message.Message,AggregationAttributes>

org.mule.extension.aggregator.internal.source.AggregatorListener

public class AggregatorListener
extends org.mule.runtime.extension.api.runtime.source.Source<org.mule.runtime.api.message.Message,AggregationAttributes>

Source for listening to events triggered by aggregator

Since:

1.0

Constructor Summary

Constructors

Constructor and Description
AggregatorListener()

Method Summary

Modifier and Type	Method and Description
String	getAggregatorName()
org.mule.runtime.extension.api.runtime.source.SourceCallback	getCallback()
AggregatorManager	getManager()
org.mule.runtime.extension.api.runtime.source.SourceCallback<org.mule.runtime.api.message.Message,AggregationAttributes>	getSourceCallback()
Boolean	getStarted()
Object	getStartLock()
boolean	isIncludeTimedOutGroups()
boolean	isStarted()
void	onStart(org.mule.runtime.extension.api.runtime.source.SourceCallback<org.mule.runtime.api.message.Message,AggregationAttributes> sourceCallback)
void	onStop()
void	setAggregatorName(String aggregatorName)
void	setIncludeTimedOutGroups(boolean includeTimedOutGroups)
void	setManager(AggregatorManager manager)
void	setSourceCallback(org.mule.runtime.extension.api.runtime.source.SourceCallback<org.mule.runtime.api.message.Message,AggregationAttributes> sourceCallback)
void	setStarted(Boolean started)
boolean	shouldIncludeTimedOutGroups()

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatorListener

public AggregatorListener()

Method Detail

getStartLock

public Object getStartLock()

getManager

public AggregatorManager getManager()

setManager

public void setManager(AggregatorManager manager)

getAggregatorName

public String getAggregatorName()

setAggregatorName

public void setAggregatorName(String aggregatorName)

isIncludeTimedOutGroups

public boolean isIncludeTimedOutGroups()

setIncludeTimedOutGroups

public void setIncludeTimedOutGroups(boolean includeTimedOutGroups)

getStarted

public Boolean getStarted()

setStarted

public void setStarted(Boolean started)

getSourceCallback

public org.mule.runtime.extension.api.runtime.source.SourceCallback<org.mule.runtime.api.message.Message,AggregationAttributes> getSourceCallback()

setSourceCallback

public void setSourceCallback(org.mule.runtime.extension.api.runtime.source.SourceCallback<org.mule.runtime.api.message.Message,AggregationAttributes> sourceCallback)

onStart

public void onStart(org.mule.runtime.extension.api.runtime.source.SourceCallback<org.mule.runtime.api.message.Message,AggregationAttributes> sourceCallback)
             throws org.mule.runtime.api.exception.MuleException

Specified by:

onStart in class org.mule.runtime.extension.api.runtime.source.Source<org.mule.runtime.api.message.Message,AggregationAttributes>

Throws:

org.mule.runtime.api.exception.MuleException

onStop

public void onStop()

Specified by:

onStop in class org.mule.runtime.extension.api.runtime.source.Source<org.mule.runtime.api.message.Message,AggregationAttributes>

isStarted

public boolean isStarted()

getCallback

public org.mule.runtime.extension.api.runtime.source.SourceCallback getCallback()

shouldIncludeTimedOutGroups

public boolean shouldIncludeTimedOutGroups()