|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.remoting.rpc.RpcManagerImpl
public class RpcManagerImpl
This component really is just a wrapper around a Transport
implementation,
and is used to set up the transport and provide lifecycle and dependency hooks into external transport
implementations.
Constructor Summary | |
---|---|
RpcManagerImpl()
|
Method Summary | |
---|---|
void |
anycastRpcCommand(List<Address> recipients,
ReplicableCommand rpc,
boolean sync)
Broadcasts an RPC command to a specified set of recipients |
void |
anycastRpcCommand(List<Address> recipients,
ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to a specified set of recipients |
Future<Object> |
anycastRpcCommandInFuture(List<Address> recipients,
ReplicableCommand rpc)
The same as RpcManager.anycastRpcCommand(java.util.List, org.infinispan.commands.ReplicableCommand, boolean) except
that the task is passed to the transport executor and a Future is returned. |
Future<Object> |
anycastRpcCommandInFuture(List<Address> recipients,
ReplicableCommand rpc,
boolean usePriorityQueue)
The same as RpcManager.anycastRpcCommand(java.util.List, org.infinispan.commands.ReplicableCommand, boolean) except
that the task is passed to the transport executor and a Future is returned. |
void |
broadcastRpcCommand(ReplicableCommand rpc,
boolean sync)
Broadcasts an RPC command to the entire cluster. |
void |
broadcastRpcCommand(ReplicableCommand rpc,
boolean sync,
boolean usePriorityQueue)
Broadcasts an RPC command to the entire cluster. |
Future<Object> |
broadcastRpcCommandInFuture(ReplicableCommand rpc)
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. |
Future<Object> |
broadcastRpcCommandInFuture(ReplicableCommand rpc,
boolean usePriorityQueue)
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. |
String |
getAddress()
|
Address |
getCurrentStateTransferSource()
If RpcManager.retrieveState(String, long) has been invoked and hasn't yet returned (i.e., a state transfer is in
progress), this method will return the current Address from which a state transfer is being attempted. |
String |
getMembers()
|
String |
getReplicationCount()
|
String |
getReplicationFailures()
|
String |
getSuccessRatio()
|
Transport |
getTransport()
|
void |
injectDependencies(Transport t,
Configuration configuration,
ReplicationQueue replicationQueue,
CommandsFactory cf,
ExecutorService e)
|
List<Response> |
invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter)
Invokes an RPC call on other caches in the cluster. |
boolean |
isStatisticsEnabled()
|
void |
resetStatistics()
|
void |
retrieveState(String cacheName,
long timeout)
Initiates a state retrieval process from neighbouring caches. |
void |
setStatisticsEnabled(boolean statisticsEnabled)
|
void |
setTransport(Transport t)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RpcManagerImpl()
Method Detail |
---|
public void injectDependencies(Transport t, Configuration configuration, ReplicationQueue replicationQueue, CommandsFactory cf, ExecutorService e)
public final List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter) throws Exception
RpcManager
invokeRemotely
in interface RpcManager
recipients
- a list of Addresses to invoke the call on. If this is null, the call is broadcast to the
entire cluster.rpcCommand
- the cache command to invokemode
- the response mode to usetimeout
- a timeout after which to throw a replication exception.usePriorityQueue
- if true, a priority queue is used to deliver messages. May not be supported by all
implementations.responseFilter
- a response filter with which to filter out failed/unwanted/invalid responses.
Exception
- in the event of problems.public final List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue) throws Exception
RpcManager
invokeRemotely
in interface RpcManager
recipients
- a list of Addresses to invoke the call on. If this is null, the call is broadcast to the
entire cluster.rpcCommand
- the cache command to invokemode
- the response mode to usetimeout
- a timeout after which to throw a replication exception.usePriorityQueue
- if true, a priority queue is used to deliver messages. May not be supported by all
implementations.
Exception
- in the event of problems.public final List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout) throws Exception
RpcManager
invokeRemotely
in interface RpcManager
recipients
- a list of Addresses to invoke the call on. If this is null, the call is broadcast to the entire
cluster.rpcCommand
- the cache command to invokemode
- the response mode to usetimeout
- a timeout after which to throw a replication exception.
Exception
- in the event of problems.public void retrieveState(String cacheName, long timeout) throws StateTransferException
RpcManager
retrieveState
in interface RpcManager
cacheName
- name of cache requesting statetimeout
- length of time to try to retrieve state on each peer
StateTransferException
- in the event of problemspublic final void broadcastRpcCommand(ReplicableCommand rpc, boolean sync) throws ReplicationException
RpcManager
broadcastRpcCommand
in interface RpcManager
rpc
- command to execute remotelysync
- if true, the transport will operate in sync mode. Otherwise, it will operate in async mode.
ReplicationException
- in the event of problemspublic final void broadcastRpcCommand(ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) throws ReplicationException
RpcManager
broadcastRpcCommand
in interface RpcManager
rpc
- command to execute remotelysync
- if true, the transport will operate in sync mode. Otherwise, it will operate in async
mode.usePriorityQueue
- if true, a priority queue is used
ReplicationException
- in the event of problemspublic final Future<Object> broadcastRpcCommandInFuture(ReplicableCommand rpc)
RpcManager
RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean)
except that the task
is passed to the transport executor and a Future is returned. The transport always deals with this
synchronously.
broadcastRpcCommandInFuture
in interface RpcManager
rpc
- command to execute remotely
public final Future<Object> broadcastRpcCommandInFuture(ReplicableCommand rpc, boolean usePriorityQueue)
RpcManager
RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean)
except that
the task is passed to the transport executor and a Future is returned. The transport always deals with this
synchronously.
broadcastRpcCommandInFuture
in interface RpcManager
rpc
- command to execute remotelyusePriorityQueue
- if true, a priority queue is used
public final void anycastRpcCommand(List<Address> recipients, ReplicableCommand rpc, boolean sync) throws ReplicationException
RpcManager
anycastRpcCommand
in interface RpcManager
recipients
- recipients to invoke remote command onrpc
- command to execute remotelysync
- if true, the transport will operate in sync mode. Otherwise, it will operate in async mode.
ReplicationException
- in the event of problemspublic final void anycastRpcCommand(List<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) throws ReplicationException
RpcManager
anycastRpcCommand
in interface RpcManager
recipients
- recipients to invoke remote command onrpc
- command to execute remotelysync
- if true, the transport will operate in sync mode. Otherwise, it will operate in async
mode.usePriorityQueue
- if true, a priority queue is used
ReplicationException
- in the event of problemspublic final Future<Object> anycastRpcCommandInFuture(List<Address> recipients, ReplicableCommand rpc)
RpcManager
RpcManager.anycastRpcCommand(java.util.List, org.infinispan.commands.ReplicableCommand, boolean)
except
that the task is passed to the transport executor and a Future is returned. The transport always deals with this
synchronously.
anycastRpcCommandInFuture
in interface RpcManager
recipients
- recipients to invoke remote call onrpc
- command to execute remotely
public final Future<Object> anycastRpcCommandInFuture(List<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue)
RpcManager
RpcManager.anycastRpcCommand(java.util.List, org.infinispan.commands.ReplicableCommand, boolean)
except
that the task is passed to the transport executor and a Future is returned. The transport always deals with this
synchronously.
anycastRpcCommandInFuture
in interface RpcManager
recipients
- recipients to invoke remote call onrpc
- command to execute remotelyusePriorityQueue
- if true, a priority queue is used
public Transport getTransport()
getTransport
in interface RpcManager
public Address getCurrentStateTransferSource()
RpcManager
RpcManager.retrieveState(String, long)
has been invoked and hasn't yet returned (i.e., a state transfer is in
progress), this method will return the current Address from which a state transfer is being attempted. Otherwise,
this method returns a null.
getCurrentStateTransferSource
in interface RpcManager
public void resetStatistics()
public String getReplicationCount()
public String getReplicationFailures()
public boolean isStatisticsEnabled()
public void setStatisticsEnabled(boolean statisticsEnabled)
public String getAddress()
public String getMembers()
public String getSuccessRatio()
public void setTransport(Transport t)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |