|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface RpcManager
Provides a mechanism for communicating with other caches in the cluster.
Implementations have a simple lifecycle:
Method Summary | |
---|---|
Address |
getCurrentStateTransferSource()
If 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. |
Address |
getLocalAddress()
Returns the local address. |
Transport |
getTransport()
|
List<Response> |
invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean stateTransferEnabled)
Invokes an RPC call on other caches in the cluster. |
List<Response> |
invokeRemotely(List<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
boolean stateTransferEnabled)
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,
boolean stateTransferEnabled)
Invokes an RPC call on other caches in the cluster. |
void |
retrieveState(String cacheName,
long timeout)
Initiates a state retrieval process from neighbouring caches. |
Methods inherited from interface org.infinispan.lifecycle.Lifecycle |
---|
start, stop |
Method Detail |
---|
List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean stateTransferEnabled) throws Exception
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.stateTransferEnabled
- if true, additional replaying is considered if messages need to be re-sent during the
course of a state transfer
Exception
- in the event of problems.List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, boolean stateTransferEnabled) throws Exception
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.stateTransferEnabled
- if true, additional replaying is considered if messages need to be re-sent during the
course of a state transfer
Exception
- in the event of problems.List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean stateTransferEnabled) throws Exception
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.stateTransferEnabled
- if true, additional replaying is considered if messages need to be re-sent during the
course of a state transfer
Exception
- in the event of problems.void retrieveState(String cacheName, long timeout) throws StateTransferException
cacheName
- name of cache requesting statetimeout
- length of time to try to retrieve state on each peer
StateTransferException
- in the event of problemsTransport getTransport()
Address getCurrentStateTransferSource()
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.
Address getLocalAddress()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |