Uses of Interface
org.jgroups.util.NotifyingFuture

Packages that use NotifyingFuture

Package	Description
org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.executor
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of NotifyingFuture in org.jgroups.blocks

Methods in org.jgroups.blocks that return NotifyingFuture

Modifier and Type	Method and Description
<T> NotifyingFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(Collection<Address> dests, MethodCall method_call, RequestOptions options) Invokes a method in all members contained in dests (or all members if dests is null).
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> NotifyingFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(Collection<Address> dests, Message msg, RequestOptions options) Sends a message to the members listed in dests.
<T> NotifyingFuture<T>	MessageDispatcher.sendMessageWithFuture(Message msg, RequestOptions options) Sends a unicast message to the target defined by msg.getDest() and returns a future
NotifyingFuture	Request.setListener(FutureListener listener)

Uses of NotifyingFuture in org.jgroups.blocks.executor

Fields in org.jgroups.blocks.executor with type parameters of type NotifyingFuture

Modifier and Type	Field and Description
protected BlockingQueue<NotifyingFuture<V>>	ExecutionCompletionService.completionQueue

Methods in org.jgroups.blocks.executor that return NotifyingFuture

Modifier and Type	Method and Description
NotifyingFuture<V>	ExecutionCompletionService.poll()
NotifyingFuture<V>	ExecutionCompletionService.poll(long timeout, TimeUnit unit)
NotifyingFuture<V>	ExecutionService.DistributedFuture.setListener(FutureListener<V> listener)
<T> NotifyingFuture<T>	ExecutionService.submit(Callable<T> task)
<T> NotifyingFuture<T>	ExecutionService.submit(Runnable task, T result)
NotifyingFuture<V>	ExecutionCompletionService.take()

Constructor parameters in org.jgroups.blocks.executor with type arguments of type NotifyingFuture

Constructor and Description
ExecutionCompletionService(ExecutionService executor, BlockingQueue<NotifyingFuture<V>> completionQueue) Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.
ExecutionCompletionService(ExecutionService executor, BlockingQueue<NotifyingFuture<V>> completionQueue, ExecutionCompletionService.QueueingListener listener) This constructor is here if someone wants to override this class and provide their own QueueingListener to possibly listen in on futures being finished

Uses of NotifyingFuture in org.jgroups.util

Methods in org.jgroups.util that return NotifyingFuture

Modifier and Type	Method and Description
NotifyingFuture	NullFuture.setListener(FutureListener<T> listener)
NotifyingFuture	NotifyingFuture.setListener(FutureListener<T> listener) Attaches a listener and returns the same future instance, to allow for 'building' futures.