Uses of Interface
org.infinispan.util.concurrent.NotifyingNotifiableFuture

Packages that use NotifyingNotifiableFuture

org.infinispan.distexec
org.infinispan.distribution	Classes relating to the distributed cache mode.
org.infinispan.remoting.rpc	Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
org.infinispan.statetransfer	Transfer of state to new caches in a cluster.
org.infinispan.util.concurrent	Thread-safe containers and other concurrency-related utilities, designed to supplement JDK concurrency utilities and containers.

Uses of NotifyingNotifiableFuture in org.infinispan.distexec

Classes in org.infinispan.distexec that implement NotifyingNotifiableFuture

protected static class

DefaultExecutorService.DistributedRunnableFuture<V> DistributedRunnableFuture is essentially a Future wrap around DistributedExecuteCommand.

Uses of NotifyingNotifiableFuture in org.infinispan.distribution

Methods in org.infinispan.distribution that return NotifyingNotifiableFuture

NotifyingNotifiableFuture<Object>	L1ManagerImpl.flushCache(Collection<Object> keys, Object retval, Address origin, boolean assumeOriginKeptEntryInL1)
NotifyingNotifiableFuture<Object>	L1Manager.flushCache(Collection<Object> keys, Object retval, Address origin, boolean assumeOriginKeptEntryInL1) Flushes a cache (using unicast or multicast) for a set of keys

Uses of NotifyingNotifiableFuture in org.infinispan.remoting.rpc

Methods in org.infinispan.remoting.rpc with parameters of type NotifyingNotifiableFuture

void	RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l)
void	RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future) The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean) except that the task is passed to the transport executor and a Future is returned.
void	RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc, NotifyingNotifiableFuture<Object> l)
void	RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future) The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l, long timeout)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout) The same as RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> l, long timeout, boolean ignoreLeavers)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout, boolean ignoreLeavers) The same as RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture, long) except that you can specify a response mode.
void	RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> l)
void	RpcManager.invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.

Uses of NotifyingNotifiableFuture in org.infinispan.statetransfer

Methods in org.infinispan.statetransfer with parameters of type NotifyingNotifiableFuture

void	BaseStateTransferManagerImpl.pushStateToNode(NotifyingNotifiableFuture<Object> stateTransferFuture, int viewId, Collection<Address> targets, Collection<InternalCacheEntry> state, Collection<LockInfo> lockInfo)

Uses of NotifyingNotifiableFuture in org.infinispan.util.concurrent

Classes in org.infinispan.util.concurrent that implement NotifyingNotifiableFuture

class	AggregatingNotifyingFutureBuilder An aggregating NotifyingNotifiableFuture implementation that allows a dynamic number of futures to be attached.
class	AggregatingNotifyingFutureImpl For use with > 1 underlying network future
class	DeferredReturnFuture<V> This is a notifying and notifiable future whose return value is not known at construction time.
class	NoOpFuture<E> A future that doesn't do anything and simply returns a given return value.
class	NotifyingFutureImpl Constructs an instance of a NotifyingFuture.

Methods in org.infinispan.util.concurrent that return NotifyingNotifiableFuture

NotifyingNotifiableFuture<?>

AggregatingNotifyingFutureBuilder.build()