Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.jboss.cache.loader
Class RpcDelegatingCacheLoader

java.lang.Object
  extended byorg.jboss.cache.loader.DelegatingCacheLoader (src) 
      extended byorg.jboss.cache.loader.RpcDelegatingCacheLoader
All Implemented Interfaces:
CacheLoader (src) , Service (src)
public class RpcDelegatingCacheLoader
extends DelegatingCacheLoader (src)

DelegatingCacheLoader implementation which delegates to a remote (not in the same VM) TreeCache using JGroups' RPC mechanism. The remote TreeCache delegated to is this cacheloader's cache's coordinator. This CacheLoader uses an optional configuration property, timeout, which specifies the timeout in milliseconds for each RPC call. If timeout is not specified, it defaults to 5000.

Field Summary
static java.lang.reflect.Method METHOD_EXISTS
           
static java.lang.reflect.Method METHOD_GET_CHILDREN_NAMES
           
static java.lang.reflect.Method METHOD_GET_STATE
           
static java.lang.reflect.Method METHOD_GET_WITH_1_PARAM
           
static java.lang.reflect.Method METHOD_GET_WITH_2_PARAMS
           
static java.lang.reflect.Method METHOD_PUT_WITH_2_PARAMS
           
static java.lang.reflect.Method METHOD_PUT_WITH_3_PARAMS
           
static java.lang.reflect.Method METHOD_REMOVE_DATA
           
static java.lang.reflect.Method METHOD_REMOVE_WITH_1_PARAM
           
static java.lang.reflect.Method METHOD_REMOVE_WITH_2_PARAMS
           
static java.lang.reflect.Method METHOD_SET_STATE
           
 
Constructor Summary
RpcDelegatingCacheLoader()
          Default constructor.
RpcDelegatingCacheLoader(TreeCache (src)  cache, int timeout)
          Allows programmatic configuration.
 
Method Summary
protected  boolean delegateExists(Fqn (src)  name)
           
protected  Node (src) delegateGet(Fqn (src)  name)
           
protected  java.lang.Object delegateGet(Fqn (src)  name, java.lang.Object key)
           
protected  java.util.Set delegateGetChildrenNames(Fqn (src)  name)
           
 byte[] delegateLoadEntireState()
           
protected  void delegatePut(Fqn (src)  name, java.util.Map attributes)
           
protected  java.lang.Object delegatePut(Fqn (src)  name, java.lang.Object key, java.lang.Object value)
           
protected  void delegateRemove(Fqn (src)  name)
           
protected  java.lang.Object delegateRemove(Fqn (src)  name, java.lang.Object key)
           
protected  void delegateRemoveData(Fqn (src)  name)
           
 void delegateStoreEntireState(byte[] state)
           
 void setCache(TreeCache (src)  cache)
          Allows configuration via XML config file.
 void setConfig(java.util.Properties props)
          Allows configuration via XML config file.
 
Methods inherited from class org.jboss.cache.loader.DelegatingCacheLoader (src)
commit, create, destroy, exists, get, get, getChildrenNames, loadEntireState, prepare, put, put, put, put, remove, remove, removeData, rollback, start, stop, storeEntireState
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

METHOD_GET_STATE

public static java.lang.reflect.Method METHOD_GET_STATE

METHOD_SET_STATE

public static java.lang.reflect.Method METHOD_SET_STATE

METHOD_GET_CHILDREN_NAMES

public static java.lang.reflect.Method METHOD_GET_CHILDREN_NAMES

METHOD_GET_WITH_2_PARAMS

public static java.lang.reflect.Method METHOD_GET_WITH_2_PARAMS

METHOD_GET_WITH_1_PARAM

public static java.lang.reflect.Method METHOD_GET_WITH_1_PARAM

METHOD_EXISTS

public static java.lang.reflect.Method METHOD_EXISTS

METHOD_PUT_WITH_3_PARAMS

public static java.lang.reflect.Method METHOD_PUT_WITH_3_PARAMS

METHOD_PUT_WITH_2_PARAMS

public static java.lang.reflect.Method METHOD_PUT_WITH_2_PARAMS

METHOD_REMOVE_WITH_2_PARAMS

public static java.lang.reflect.Method METHOD_REMOVE_WITH_2_PARAMS

METHOD_REMOVE_WITH_1_PARAM

public static java.lang.reflect.Method METHOD_REMOVE_WITH_1_PARAM

METHOD_REMOVE_DATA

public static java.lang.reflect.Method METHOD_REMOVE_DATA
Constructor Detail

RpcDelegatingCacheLoader

public RpcDelegatingCacheLoader()
Default constructor.

RpcDelegatingCacheLoader

public RpcDelegatingCacheLoader(TreeCache (src)  cache,
                                int timeout)
Allows programmatic configuration.

Parameters:
timeout - The timeout in milliseconds for each RPC call.
Method Detail

setConfig

public void setConfig(java.util.Properties props)
Allows configuration via XML config file.

Specified by:
setConfig in interface CacheLoader (src)
Specified by:
setConfig in class DelegatingCacheLoader (src)
See Also:
DelegatingCacheLoader.setConfig(java.util.Properties)

setCache

public void setCache(TreeCache (src)  cache)
Allows configuration via XML config file.

Specified by:
setCache in interface CacheLoader (src)
Specified by:
setCache in class DelegatingCacheLoader (src)
See Also:
DelegatingCacheLoader.setCache(org.jboss.cache.TreeCache)

delegateGetChildrenNames

protected java.util.Set delegateGetChildrenNames(Fqn (src)  name)
                                          throws java.lang.Exception
Specified by:
delegateGetChildrenNames in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateGetChildrenNames(org.jboss.cache.Fqn)

delegateGet

protected java.lang.Object delegateGet(Fqn (src)  name,
                                       java.lang.Object key)
                                throws java.lang.Exception
Specified by:
delegateGet in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateGet(org.jboss.cache.Fqn, java.lang.Object)

delegateGet

protected Node (src)  delegateGet(Fqn (src)  name)
                    throws java.lang.Exception
Specified by:
delegateGet in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateGet(org.jboss.cache.Fqn)

delegateExists

protected boolean delegateExists(Fqn (src)  name)
                          throws java.lang.Exception
Specified by:
delegateExists in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateExists(org.jboss.cache.Fqn)

delegatePut

protected java.lang.Object delegatePut(Fqn (src)  name,
                                       java.lang.Object key,
                                       java.lang.Object value)
                                throws java.lang.Exception
Specified by:
delegatePut in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegatePut(org.jboss.cache.Fqn, java.lang.Object, java.lang.Object)

delegatePut

protected void delegatePut(Fqn (src)  name,
                           java.util.Map attributes)
                    throws java.lang.Exception
Specified by:
delegatePut in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegatePut(org.jboss.cache.Fqn, java.util.Map)

delegateRemove

protected java.lang.Object delegateRemove(Fqn (src)  name,
                                          java.lang.Object key)
                                   throws java.lang.Exception
Specified by:
delegateRemove in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateRemove(org.jboss.cache.Fqn, java.lang.Object)

delegateRemove

protected void delegateRemove(Fqn (src)  name)
                       throws java.lang.Exception
Specified by:
delegateRemove in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateRemove(org.jboss.cache.Fqn)

delegateRemoveData

protected void delegateRemoveData(Fqn (src)  name)
                           throws java.lang.Exception
Specified by:
delegateRemoveData in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateRemoveData(org.jboss.cache.Fqn)

delegateLoadEntireState

public byte[] delegateLoadEntireState()
                               throws java.lang.Exception
Specified by:
delegateLoadEntireState in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateLoadEntireState()

delegateStoreEntireState

public void delegateStoreEntireState(byte[] state)
                              throws java.lang.Exception
Specified by:
delegateStoreEntireState in class DelegatingCacheLoader (src)
Throws:
java.lang.Exception
See Also:
DelegatingCacheLoader.delegateStoreEntireState(byte[])
Overview  Package   Class  Tree  Deprecated  Index  Help 
 PREV CLASS (src)    NEXT CLASS (src) FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD