|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.jboss.cache.RPCManagerImpl
public class RPCManagerImpl
Manager that handles all RPC calls between JBoss Cache instances
Nested Class Summary | |
---|---|
class |
RPCManagerImpl.FlushTracker
|
protected class |
RPCManagerImpl.MembershipListenerAdaptor
|
Constructor Summary | |
---|---|
RPCManagerImpl()
|
Method Summary | |
---|---|
List<Object> |
callRemoteMethods(Vector<org.jgroups.Address> recipients,
ReplicableCommand command,
boolean synchronous,
long timeout,
boolean useOutOfBandMessage)
Invokes an RPC call on other caches in the cluster. |
List<Object> |
callRemoteMethods(Vector<org.jgroups.Address> recipients,
ReplicableCommand command,
int mode,
long timeout,
boolean useOutOfBandMessage)
Invokes an RPC call on other caches in the cluster. |
List<Object> |
callRemoteMethods(Vector<org.jgroups.Address> recipients,
ReplicableCommand command,
int mode,
long timeout,
org.jgroups.blocks.RspFilter responseFilter,
boolean useOutOfBandMessage)
Invokes an RPC call on other caches in the cluster. |
void |
disconnect()
Disconnects and closes the underlying JGroups channel. |
void |
fetchPartialState(List<org.jgroups.Address> sources,
Fqn subtree)
Retrieves partial state from remote instances. |
void |
fetchPartialState(List<org.jgroups.Address> sources,
Fqn sourceTarget,
Fqn integrationTarget)
Retrieves partial state from remote instances. |
org.jgroups.Channel |
getChannel()
Retrieves the Channel |
org.jgroups.Address |
getCoordinator()
|
RPCManagerImpl.FlushTracker |
getFlushTracker()
Returns the flush tracker associated with this manager. |
org.jgroups.Address |
getLastStateTransferSource()
Returns the last state transfer source address. |
org.jgroups.Address |
getLocalAddress()
Retrieves the local JGroups channel's address |
String |
getLocalAddressString()
|
List<org.jgroups.Address> |
getMembers()
Returns a defensively copied list of members in the current cluster view. |
String |
getMembersString()
|
long |
getReplicationCount()
|
long |
getReplicationFailures()
|
String |
getSuccessRatio()
|
boolean |
isCoordinator()
|
boolean |
isEnabled()
|
boolean |
isStatisticsEnabled()
|
void |
resetStatistics()
|
void |
setStatisticsEnabled(boolean statisticsEnabled)
|
void |
setupDependencies(ChannelMessageListener messageListener,
Configuration configuration,
Notifier notifier,
CacheSPI spi,
Marshaller marshaller,
TransactionTable txTable,
TransactionManager txManager,
InvocationContextContainer container,
InterceptorChain interceptorChain,
ComponentRegistry componentRegistry,
LockManager lockManager)
|
void |
start()
Starts the RPCManager by connecting the underlying JGroups channel (if configured for replication). |
void |
stop()
Stops the RPCDispatcher and frees resources. |
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 setupDependencies(ChannelMessageListener messageListener, Configuration configuration, Notifier notifier, CacheSPI spi, Marshaller marshaller, TransactionTable txTable, TransactionManager txManager, InvocationContextContainer container, InterceptorChain interceptorChain, ComponentRegistry componentRegistry, LockManager lockManager)
public void start()
RPCManager
start
in interface RPCManager
public void disconnect()
RPCManager
disconnect
in interface RPCManager
public void stop()
RPCManager
stop
in interface RPCManager
public org.jgroups.Channel getChannel()
RPCManager
getChannel
in interface RPCManager
public List<Object> callRemoteMethods(Vector<org.jgroups.Address> recipients, ReplicableCommand command, int mode, long timeout, boolean useOutOfBandMessage) throws Exception
RPCManager
callRemoteMethods
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.command
- the cache command to invokemode
- the group request mode to use. See GroupRequest
.timeout
- a timeout after which to throw a replication exception.useOutOfBandMessage
- if true, the message is put on JGroups' OOB queue. See JGroups docs for more info.
Exception
- in the event of problems.public List<Object> callRemoteMethods(Vector<org.jgroups.Address> recipients, ReplicableCommand command, boolean synchronous, long timeout, boolean useOutOfBandMessage) throws Exception
RPCManager
callRemoteMethods
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.command
- the cache command to invokesynchronous
- if true, sets group request mode to GroupRequest.GET_ALL
, and if false sets it to GroupRequest.GET_NONE
.timeout
- a timeout after which to throw a replication exception.useOutOfBandMessage
- if true, the message is put on JGroups' OOB queue. See JGroups docs for more info.
Exception
- in the event of problems.public List<Object> callRemoteMethods(Vector<org.jgroups.Address> recipients, ReplicableCommand command, int mode, long timeout, org.jgroups.blocks.RspFilter responseFilter, boolean useOutOfBandMessage) throws Exception
RPCManager
callRemoteMethods
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.command
- the cache command to invokemode
- the group request mode to use. See GroupRequest
.timeout
- a timeout after which to throw a replication exception.responseFilter
- a response filter with which to filter out failed/unwanted/invalid responses.useOutOfBandMessage
- if true, the message is put on JGroups' OOB queue. See JGroups docs for more info.
Exception
- in the event of problems.public void fetchPartialState(List<org.jgroups.Address> sources, Fqn sourceTarget, Fqn integrationTarget) throws Exception
RPCManager
fetchPartialState
in interface RPCManager
sources
- sources to consider for a state transfersourceTarget
- Fqn on source to retrieve state forintegrationTarget
- integration point on local cache to apply state
Exception
- in the event of problemspublic void fetchPartialState(List<org.jgroups.Address> sources, Fqn subtree) throws Exception
RPCManager
fetchPartialState
in interface RPCManager
sources
- sources to consider for a state transfersubtree
- Fqn subtree to retrieve. Will be integrated at the same point.
Exception
- in the event of problemspublic String getLocalAddressString()
public org.jgroups.Address getLastStateTransferSource()
RPCManager
getLastStateTransferSource
in interface RPCManager
public org.jgroups.Address getLocalAddress()
RPCManager
getLocalAddress
in interface RPCManager
public String getMembersString()
public List<org.jgroups.Address> getMembers()
RPCManager
getMembers
in interface RPCManager
public boolean isCoordinator()
isCoordinator
in interface RPCManager
public org.jgroups.Address getCoordinator()
getCoordinator
in interface RPCManager
public void resetStatistics()
public long getReplicationCount()
public long getReplicationFailures()
public boolean isStatisticsEnabled()
public boolean isEnabled()
public void setStatisticsEnabled(boolean statisticsEnabled)
public String getSuccessRatio()
public RPCManagerImpl.FlushTracker getFlushTracker()
RPCManager
getFlushTracker
in interface RPCManager
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |