|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.remoting.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 | |
---|---|
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. |
Address |
getLocalAddress()
Returns the local address. |
String |
getMembers()
|
String |
getReplicationCount()
|
String |
getReplicationFailures()
|
String |
getSuccessRatio()
|
Transport |
getTransport()
|
void |
injectDependencies(GlobalConfiguration globalConfiguration,
Transport t,
InboundInvocationHandler handler,
Marshaller marshaller,
ExecutorService e,
CacheManagerNotifier notifier)
|
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. |
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)
|
void |
start()
|
void |
stop()
|
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(GlobalConfiguration globalConfiguration, Transport t, InboundInvocationHandler handler, Marshaller marshaller, ExecutorService e, CacheManagerNotifier notifier)
public void start()
start
in interface Lifecycle
public void stop()
stop
in interface Lifecycle
public List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter, boolean stateTransferEnabled) 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.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.public List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, boolean stateTransferEnabled) 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.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.public List<Response> invokeRemotely(List<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean stateTransferEnabled) 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.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.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 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 Address getLocalAddress()
RpcManager
getLocalAddress
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 |