Package | Description |
---|---|
org.infinispan.commons.util.concurrent | |
org.infinispan.remoting.rpc |
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
|
org.infinispan.stats.wrappers |
Modifier and Type | Class and Description |
---|---|
class |
AggregatingNotifyingFutureImpl<T>
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<T>
Constructs an instance of a
NotifyingFuture . |
Modifier and Type | Method and Description |
---|---|
void |
RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
void |
RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> l) |
void |
RpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
void |
RpcManagerImpl.broadcastRpcCommandInFuture(ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> l) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
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,
long timeout)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
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,
boolean ignoreLeavers)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
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,
NotifyingNotifiableFuture<Object> future)
Deprecated.
this method may be removed in the future. Use
#invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions, org.infinispan.util.concurrent.NotifyingNotifiableFuture) |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> l) |
void |
RpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options,
NotifyingNotifiableFuture<Object> future)
The same as
RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions)
except that the task is passed to the transport executor and a Future is returned. |
void |
RpcManagerImpl.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options,
NotifyingNotifiableFuture<Object> future) |
Modifier and Type | Method and Description |
---|---|
void |
ExtendedStatisticRpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future) |
void |
ExtendedStatisticRpcManager.broadcastRpcCommandInFuture(ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue,
NotifyingNotifiableFuture<Object> future,
long timeout,
boolean ignoreLeavers) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
NotifyingNotifiableFuture<Object> future) |
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options,
NotifyingNotifiableFuture<Object> future) |
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.