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(List<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l)
|
void |
RpcManager.invokeRemotelyInFuture(List<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future)
The same as RpcManager.invokeRemotely(java.util.List, org.infinispan.commands.ReplicableCommand, boolean) except
that the task is passed to the transport executor and a Future is returned. |
void |
RpcManagerImpl.invokeRemotelyInFuture(List<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l,
long timeout)
|
void |
RpcManager.invokeRemotelyInFuture(List<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout)
The same as RpcManager.invokeRemotelyInFuture(java.util.List, org.infinispan.commands.ReplicableCommand, boolean,
org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout. |
void |
RpcManagerImpl.invokeRemotelyInFuture(List<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> l)
|
void |
RpcManager.invokeRemotelyInFuture(List<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future)
The same as RpcManager.invokeRemotely(java.util.List, org.infinispan.commands.ReplicableCommand, boolean) except
that the task is passed to the transport executor and a Future is returned. |