jadex.bridge.service.component.multiinvoke

Class FlattenMultiplexCollector

java.lang.Object

jadex.bridge.service.component.multiinvoke.FlattenMultiplexCollector

All Implemented Interfaces:

IMultiplexCollector, IFunctionalExceptionListener, IFunctionalIntermediateFinishedListener, IFunctionalIntermediateResultListener<java.lang.Object>, IFunctionalResultListener<java.util.Collection<java.lang.Object>>, IIntermediateResultListener<java.lang.Object>, IResultListener<java.util.Collection<java.lang.Object>>

public class FlattenMultiplexCollector
extends java.lang.Object
implements IMultiplexCollector

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.List<java.lang.Object>	callresults The list of results (if ret is not intermediate future).
protected java.util.List<Future<java.lang.Void>>	calls The list of calls.
protected boolean	flatten Flag if flatten.
protected Future<java.lang.Object>	fut The future.

Constructor Summary

Constructors

Constructor and Description
FlattenMultiplexCollector()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

fut

protected Future<java.lang.Object> fut

The future.

flatten

protected boolean flatten

Flag if flatten.

calls

protected java.util.List<Future<java.lang.Void>> calls

The list of calls.

callresults

protected java.util.List<java.lang.Object> callresults

The list of results (if ret is not intermediate future).

Constructor Detail

FlattenMultiplexCollector

public FlattenMultiplexCollector()

Method Detail

init

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

Init to share code.

Specified by:

init in interface IMultiplexCollector

intermediateResultAvailable

public void intermediateResultAvailable(java.lang.Object result)

Description copied from interface: IIntermediateResultListener

Called when an intermediate result is available.

Specified by:

intermediateResultAvailable in interface IFunctionalIntermediateResultListener<java.lang.Object>

Specified by:

intermediateResultAvailable in interface IIntermediateResultListener<java.lang.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 IFunctionalIntermediateFinishedListener

Specified by:

finished in interface IIntermediateResultListener<java.lang.Object>

resultAvailable

public void resultAvailable(java.util.Collection<java.lang.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 IFunctionalResultListener<java.util.Collection<java.lang.Object>>

Specified by:

resultAvailable in interface IIntermediateResultListener<java.lang.Object>

Parameters:

result - The final result.

exceptionOccurred

public void exceptionOccurred(java.lang.Exception exception)

Description copied from interface: IFunctionalExceptionListener

Called when an exception occurred.

Specified by:

exceptionOccurred in interface IFunctionalExceptionListener

Parameters:

exception - The exception.

addResult

protected void addResult(java.lang.Object result)

Add a result.

Parameters:

result - The result.

setFinished

protected void setFinished()

Set finished.

setException

protected void setException(java.lang.Exception exception)

Set an exception.

Parameters:

exception - The exception.