org.jboss.cache
Class RPCManagerImpl
java.lang.Object
org.jboss.cache.RPCManagerImpl
- All Implemented Interfaces:
- RPCManager
public class RPCManagerImpl
- extends java.lang.Object
- implements RPCManager
Manager that handles all RPC calls between JBoss Cache instances
- Author:
- Manik Surtani (manik@jboss.org)
Method Summary |
java.util.List |
callRemoteMethods(java.util.List<org.jgroups.Address> recipients,
MethodCall methodCall,
boolean synchronous,
boolean excludeSelf,
int timeout)
|
java.util.List |
callRemoteMethods(java.util.List<org.jgroups.Address> recipients,
MethodCall methodCall,
int mode,
boolean excludeSelf,
long timeout)
|
java.util.List |
callRemoteMethods(java.util.List<org.jgroups.Address> recipients,
java.lang.reflect.Method method,
java.lang.Object[] arguments,
boolean synchronous,
boolean excludeSelf,
long timeout)
|
org.jgroups.Address |
getCoordinator()
|
ReplicationQueue |
getReplicationQueue()
|
boolean |
isCoordinator()
|
void |
setCache(CacheSPI c)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
RPCManagerImpl
public RPCManagerImpl()
- Empty ctor for mock object creation/unit testing
RPCManagerImpl
public RPCManagerImpl(CacheSPI c)
callRemoteMethods
public java.util.List callRemoteMethods(java.util.List<org.jgroups.Address> recipients,
MethodCall methodCall,
int mode,
boolean excludeSelf,
long timeout)
throws java.lang.Exception
- Specified by:
callRemoteMethods
in interface RPCManager
- Throws:
java.lang.Exception
isCoordinator
public boolean isCoordinator()
- Specified by:
isCoordinator
in interface RPCManager
getCoordinator
public org.jgroups.Address getCoordinator()
- Specified by:
getCoordinator
in interface RPCManager
callRemoteMethods
public java.util.List callRemoteMethods(java.util.List<org.jgroups.Address> recipients,
MethodCall methodCall,
boolean synchronous,
boolean excludeSelf,
int timeout)
throws java.lang.Exception
- Specified by:
callRemoteMethods
in interface RPCManager
- Throws:
java.lang.Exception
callRemoteMethods
public java.util.List callRemoteMethods(java.util.List<org.jgroups.Address> recipients,
java.lang.reflect.Method method,
java.lang.Object[] arguments,
boolean synchronous,
boolean excludeSelf,
long timeout)
throws java.lang.Exception
- Specified by:
callRemoteMethods
in interface RPCManager
- Throws:
java.lang.Exception
setCache
public void setCache(CacheSPI c)
- Specified by:
setCache
in interface RPCManager
getReplicationQueue
public ReplicationQueue getReplicationQueue()
- Specified by:
getReplicationQueue
in interface RPCManager
- Returns:
- Returns the replication queue (if one is used), null otherwise.