org.jboss.cache
Class RPCManagerImpl

java.lang.Object
  org.jboss.cache.RPCManagerImpl

All Implemented Interfaces:

RPCManager

public class RPCManagerImpl
extends 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

List	callRemoteMethods(List<org.jgroups.Address> recipients, MethodCall methodCall, boolean synchronous, boolean excludeSelf, int timeout)
List	callRemoteMethods(List<org.jgroups.Address> recipients, MethodCall methodCall, int mode, boolean excludeSelf, long timeout)
List	callRemoteMethods(List<org.jgroups.Address> recipients, MethodCall methodCall, int mode, boolean excludeSelf, long timeout, org.jgroups.blocks.RspFilter responseFilter) The same as RPCManager.callRemoteMethods(java.util.List,org.jboss.cache.marshall.MethodCall,int,boolean,long) except that it adds a JGroups RspFilter to the list of parameters, which is used to filter results.
List	callRemoteMethods(List<org.jgroups.Address> recipients, Method method, 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 List callRemoteMethods(List<org.jgroups.Address> recipients,
                              MethodCall methodCall,
                              int mode,
                              boolean excludeSelf,
                              long timeout,
                              org.jgroups.blocks.RspFilter responseFilter)
                       throws Exception

Description copied from interface: RPCManager

The same as RPCManager.callRemoteMethods(java.util.List,org.jboss.cache.marshall.MethodCall,int,boolean,long) except that it adds a JGroups RspFilter to the list of parameters, which is used to filter results.

Specified by:

callRemoteMethods in interface RPCManager

Throws:

Exception

callRemoteMethods

public List callRemoteMethods(List<org.jgroups.Address> recipients,
                              MethodCall methodCall,
                              int mode,
                              boolean excludeSelf,
                              long timeout)
                       throws Exception

Specified by:

callRemoteMethods in interface RPCManager

Throws:

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 List callRemoteMethods(List<org.jgroups.Address> recipients,
                              MethodCall methodCall,
                              boolean synchronous,
                              boolean excludeSelf,
                              int timeout)
                       throws Exception

Specified by:

callRemoteMethods in interface RPCManager

Throws:

Exception

callRemoteMethods

public List callRemoteMethods(List<org.jgroups.Address> recipients,
                              Method method,
                              Object[] arguments,
                              boolean synchronous,
                              boolean excludeSelf,
                              long timeout)
                       throws Exception

Specified by:

callRemoteMethods in interface RPCManager

Throws:

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.