jadex.bridge.service.component.interceptors

Class FutureFunctionality

java.lang.Object

jadex.bridge.service.component.interceptors.FutureFunctionality

Direct Known Subclasses:

ComponentFutureFunctionality

public class FutureFunctionality
extends Object

Default future functionality.

Constructor Summary

Constructors

Constructor and Description
FutureFunctionality(Logger logger)

Method Summary

Methods

Modifier and Type	Method and Description
Object	addIntermediateResult(Object result)
Object	addIntermediateResultIfUndone(Object result)
static void	connectDelegationFuture(Future target, IFuture source) Connect a delegation future with the source.
static Future	getDelegationFuture(Class<?> clazz, FutureFunctionality func)
static Future	getDelegationFuture(IFuture<?> orig, FutureFunctionality func)
void	notifyListener(IResultListener<Void> notify) Notify the listener.
Exception	setException(Exception exception)
Exception	setExceptionIfUndone(Exception exception)
void	setFinished(Collection<Object> results)
void	setFinishedIfUndone(Collection<Object> results)
Object	setResult(Object result)
Object	setResultIfUndone(Object result)
void	startScheduledNotifications(IResultListener<Void> notify) Start the notifications.
IFuture<Void>	terminate(Exception reason) Terminate the future.

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureFunctionality

public FutureFunctionality(Logger logger)

Method Detail

addIntermediateResult

public Object addIntermediateResult(Object result)

addIntermediateResultIfUndone

public Object addIntermediateResultIfUndone(Object result)

setFinished

public void setFinished(Collection<Object> results)

setFinishedIfUndone

public void setFinishedIfUndone(Collection<Object> results)

setResult

public Object setResult(Object result)

setResultIfUndone

public Object setResultIfUndone(Object result)

setException

public Exception setException(Exception exception)

setExceptionIfUndone

public Exception setExceptionIfUndone(Exception exception)

terminate

public IFuture<Void> terminate(Exception reason)

Terminate the future.

notifyListener

public void notifyListener(IResultListener<Void> notify)

Notify the listener.

startScheduledNotifications

public void startScheduledNotifications(IResultListener<Void> notify)

Start the notifications.

getDelegationFuture

public static Future getDelegationFuture(IFuture<?> orig,
                         FutureFunctionality func)

getDelegationFuture

public static Future getDelegationFuture(Class<?> clazz,
                         FutureFunctionality func)

connectDelegationFuture

public static void connectDelegationFuture(Future target,
                           IFuture source)

Connect a delegation future with the source. Add delegation listener on the source (+ termination handling).