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
org.mule.runtime.extension.api.runtime.source.SourceCallback	getCallback()
boolean	isStarted()
void	onStart(org.mule.runtime.extension.api.runtime.source.SourceCallback<org.mule.runtime.api.message.Message,AggregationAttributes> sourceCallback)
void	onStop()
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

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