org.mule.api

Class FutureMessageResult

java.lang.Object

java.util.concurrent.FutureTask

org.mule.api.FutureMessageResult

All Implemented Interfaces:

Runnable, Future, RunnableFuture

public class FutureMessageResult
extends FutureTask

FutureMessageResult is an MuleMessage result of a remote invocation on a Mule Server. This object makes the result available to the client code once the request has been processed. This execution happens asynchronously.

Field Summary

Fields

Modifier and Type	Field and Description
protected MuleContext	muleContext

Constructor Summary

Constructors

Constructor and Description
FutureMessageResult(Callable callable, MuleContext muleContext)

Method Summary

Methods

Modifier and Type	Method and Description
void	execute() Start asynchronous execution of this task
MuleMessage	getMessage()
MuleMessage	getMessage(long timeout)
void	setExecutor(Executor e) Set an ExecutorService to run this invocation.
void	setTransformers(List t) Set a post-invocation transformer.

Methods inherited from class java.util.concurrent.FutureTask

cancel, done, get, get, isCancelled, isDone, run, runAndReset, set, setException

Methods inherited from class java.lang.Object

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

Field Detail

muleContext

protected MuleContext muleContext

Constructor Detail

FutureMessageResult

public FutureMessageResult(Callable callable,
                   MuleContext muleContext)

Method Detail

setExecutor

public void setExecutor(Executor e)

Set an ExecutorService to run this invocation.

Parameters:

e - the executor to be used.

Throws:

IllegalArgumentException - when the executor is null or shutdown.

setTransformers

public void setTransformers(List t)

Set a post-invocation transformer.

Parameters:

t - Transformers to be applied to the result of this invocation. May be null.

getMessage

public MuleMessage getMessage()
                       throws InterruptedException,
                              ExecutionException,
                              MuleException

Throws:

InterruptedException

ExecutionException

MuleException

getMessage

public MuleMessage getMessage(long timeout)
                       throws InterruptedException,
                              ExecutionException,
                              TimeoutException,
                              MuleException

Throws:

InterruptedException

ExecutionException

TimeoutException

MuleException

execute

public void execute()

Start asynchronous execution of this task