jadex.bridge.service.component.multiinvoke

Class FlattenMultiplexCollector

java.lang.Object

jadex.bridge.service.component.multiinvoke.FlattenMultiplexCollector

All Implemented Interfaces:

IMultiplexCollector, IIntermediateResultListener<Object>, IResultListener<Collection<Object>>

public class FlattenMultiplexCollector
extends Object
implements IMultiplexCollector

Constructor Summary

Constructors

Constructor and Description
FlattenMultiplexCollector()

Method Summary

Methods

Modifier and Type	Method and Description
void	exceptionOccurred(Exception exception) Called when an exception occurred.
void	finished() Declare that the future is finished.
void	init(Future<Object> fut, Method method, Object[] args, Method muxmethod) Init to share code.
void	intermediateResultAvailable(Object result) Called when an intermediate result is available.
void	resultAvailable(Collection<Object> result) Called when the result is available.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlattenMultiplexCollector

public FlattenMultiplexCollector()

Method Detail

init

public void init(Future<Object> fut,
        Method method,
        Object[] args,
        Method muxmethod)

Init to share code.

Specified by:

init in interface IMultiplexCollector

intermediateResultAvailable

public void intermediateResultAvailable(Object result)

Description copied from interface: IIntermediateResultListener

Called when an intermediate result is available.

Specified by:

intermediateResultAvailable in interface IIntermediateResultListener<Object>

Parameters:

result - The result.

finished

public void finished()

Description copied from interface: IIntermediateResultListener

Declare that the future is finished. This method is only called for intermediate futures, i.e. when this method is called it is guaranteed that the intermediateResultAvailable method was called for all intermediate results before.

Specified by:

finished in interface IIntermediateResultListener<Object>

resultAvailable

public void resultAvailable(Collection<Object> result)

Description copied from interface: IIntermediateResultListener

Called when the result is available. This method is only called for non-intermediate futures, i.e. when this method is called it is guaranteed that the intermediateResultAvailable method has not been called.

Specified by:

resultAvailable in interface IIntermediateResultListener<Object>

Specified by:

resultAvailable in interface IResultListener<Collection<Object>>

Parameters:

result - The final result.

exceptionOccurred

public void exceptionOccurred(Exception exception)

Description copied from interface: IResultListener

Called when an exception occurred.

Specified by:

exceptionOccurred in interface IResultListener<Collection<Object>>

Parameters:

exception - The exception.