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(IResultCommand<Logger,Void> loggerfetcher)
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)
boolean	isUndone() Get the undone.
void	notifyListener(IResultListener<Void> notify) Notify the listener.
void	pullIntermediateResult(IResultListener<Void> notify) Pull an intermediate result.
void	sendBackwardCommand(Object info, IResultListener<Void> com) Send a backward command.
void	sendForwardCommand(Object info, IResultListener<Void> com) Send a foward command.
Exception	setException(Exception exception)
Exception	setExceptionIfUndone(Exception exception)
void	setFinished(Collection<Object> results)
void	setFinishedIfUndone(Collection<Object> results)
Object	setFirstResult(Object result)
Object	setResult(Object result)
Object	setResultIfUndone(Object result)
Object	setSecondResult(Object result)
void	startScheduledNotifications(IResultListener<Void> notify) Start the notifications.
void	terminate(Exception reason, IResultListener<Void> terminate) 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)

FutureFunctionality

public FutureFunctionality(IResultCommand<Logger,Void> loggerfetcher)

Method Detail

isUndone

public boolean isUndone()

Get the undone.

Returns:

The undone.

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 void terminate(Exception reason,
             IResultListener<Void> terminate)

Terminate the future.

sendForwardCommand

public void sendForwardCommand(Object info,
                      IResultListener<Void> com)

Send a foward command.

sendBackwardCommand

public void sendBackwardCommand(Object info,
                       IResultListener<Void> com)

Send a backward command.

notifyListener

public void notifyListener(IResultListener<Void> notify)

Notify the listener.

startScheduledNotifications

public void startScheduledNotifications(IResultListener<Void> notify)

Start the notifications.

pullIntermediateResult

public void pullIntermediateResult(IResultListener<Void> notify)

Pull an intermediate result.

setFirstResult

public Object setFirstResult(Object result)

setSecondResult

public Object setSecondResult(Object result)

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