org.jboss.cache
Class RPCManagerImpl

java.lang.Object
  extended by 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)

Constructor Summary
RPCManagerImpl()
          Empty ctor for mock object creation/unit testing
RPCManagerImpl(CacheSPI c)
           
 
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
 

Constructor Detail

RPCManagerImpl

public RPCManagerImpl()
Empty ctor for mock object creation/unit testing


RPCManagerImpl

public RPCManagerImpl(CacheSPI c)
Method Detail

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.