|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
MBean interface.
Field Summary |
Fields inherited from interface org.jboss.system.ServiceMBean |
CREATE_EVENT, CREATED, DESTROY_EVENT, DESTROYED, FAILED, REGISTERED, START_EVENT, STARTED, STARTING, states, STOP_EVENT, STOPPED, STOPPING, UNREGISTERED |
Method Summary | |
void |
_put(GlobalTransaction tx,
Fqn fqn,
Map data,
boolean create_undo_ops)
Does the real work. |
void |
_put(GlobalTransaction tx,
Fqn fqn,
Map data,
boolean create_undo_ops,
boolean erase_contents)
Does the real work. |
Object |
_put(GlobalTransaction tx,
Fqn fqn,
Object key,
Object value,
boolean create_undo_ops)
|
void |
_put(GlobalTransaction tx,
String fqn,
Map data,
boolean create_undo_ops)
Does the real work. |
Object |
_put(GlobalTransaction tx,
String fqn,
Object key,
Object value,
boolean create_undo_ops)
|
void |
_remove(GlobalTransaction tx,
Fqn fqn,
boolean create_undo_ops)
|
Object |
_remove(GlobalTransaction tx,
Fqn fqn,
Object key,
boolean create_undo_ops)
|
void |
_remove(GlobalTransaction tx,
String fqn,
boolean create_undo_ops)
|
Object |
_remove(GlobalTransaction tx,
String fqn,
Object key,
boolean create_undo_ops)
|
void |
addTreeCacheListener(TreeCacheListener listener)
|
List |
callRemoteMethods(Vector members,
Method method,
Object[] args,
boolean synchronous,
boolean exclude_self,
long timeout)
|
List |
callRemoteMethods(Vector members,
String method_name,
Class[] types,
Object[] args,
boolean synchronous,
boolean exclude_self,
long timeout)
|
void |
createService()
|
void |
destroyService()
|
String |
dumpTransactionTable()
Dumps the contents of the TransactionTable |
void |
evict(Fqn fqn)
Called by eviction policy provider. |
void |
evict(Fqn fqn,
Object key)
Evicts a key/value pair from a node's attributes. |
boolean |
exists(Fqn fqn)
Checks whether a given node exists in the tree. |
boolean |
exists(Fqn fqn,
Object key)
Checks whether a given key exists in the given node. |
boolean |
exists(String fqn)
Checks whether a given node exists in the tree |
boolean |
exists(String fqn,
Object key)
|
void |
fetchState(long timeout)
Fetch the group state from the current coordinator. |
Object |
get(Fqn fqn,
Object key)
Finds a node given its name and returns the value associated with a given key in its data map. |
Object |
get(String fqn,
Object key)
Finds a node given its name and returns the value associated with a given key in its data map. |
CacheLoader |
getCacheLoader()
|
String |
getCacheLoaderClass()
|
Properties |
getCacheLoaderConfig()
|
boolean |
getCacheLoaderFetchPersistentState()
|
boolean |
getCacheLoaderFetchTransientState()
|
String |
getCacheLoaderPreload()
|
boolean |
getCacheLoaderShared()
|
String |
getCacheMode()
Returns the current caching mode. |
Set |
getChildrenNames(Fqn fqn)
Returns all children of a given node |
Set |
getChildrenNames(String fqn)
Returns all children of a given node |
String |
getClusterName()
Get the name of the replication group |
String |
getClusterProperties()
Get the cluster properties (e.g. |
String |
getEvictionPolicyClass()
Returns the name of the cache eviction policy (must be an implementation of EvictionPolicy) |
int |
getEvictionThreadWakeupIntervalSeconds()
Obtain eviction thread (if any) wake up interval in seconds |
boolean |
getFetchStateOnStartup()
|
long |
getInitialStateRetrievalTimeout()
Get the max time to wait until the initial state is retrieved. |
TreeCache |
getInstance()
|
String |
getInterceptorChain()
|
List |
getInterceptors()
|
String |
getIsolationLevel()
Returns the transaction isolation level. |
String |
getJndiName()
|
Set |
getKeys(Fqn fqn)
|
Set |
getKeys(String fqn)
|
Object |
getLocalAddress()
|
long |
getLockAcquisitionTimeout()
Default max time to wait for a lock. |
Vector |
getMembers()
|
int |
getNumberOfAttributes()
Returns an approximation of the total number of attributes in the tree. |
int |
getNumberOfLocksHeld()
Gets the number of read or write locks held across the entire tree |
int |
getNumberOfNodes()
Returns an approximation of the total number of nodes in the tree. |
long |
getReplQueueInterval()
|
int |
getReplQueueMaxElements()
|
boolean |
getSyncCommitPhase()
|
long |
getSyncReplTimeout()
Returns the default max timeout after which synchronous replication calls return. |
boolean |
getSyncRollbackPhase()
|
TransactionManager |
getTransactionManager()
|
String |
getTransactionManagerLookupClass()
|
boolean |
getUseReplQueue()
|
boolean |
isCoordinator()
|
void |
load(String fqn)
Loads the indicated Fqn, plus all parents recursively from the CacheLoader. |
String |
print(Fqn fqn)
Prints a representation of the node defined by fqn . |
String |
print(String fqn)
Prints a representation of the node defined by fqn . |
String |
printDetails()
|
String |
printLockInfo()
|
void |
put(Fqn fqn,
Map data)
Adds a new node to the tree and sets its data. |
Object |
put(Fqn fqn,
Object key,
Object value)
Adds a key and value to a given node. |
void |
put(String fqn,
Map data)
Adds a new node to the tree and sets its data. |
Object |
put(String fqn,
Object key,
Object value)
Adds a key and value to a given node. |
void |
releaseAllLocks(Fqn fqn)
Force-releases all locks in this node and the entire subtree |
void |
releaseAllLocks(String fqn)
Force-releases all locks in this node and the entire subtree |
void |
remove(Fqn fqn)
Removes the node from the tree. |
Object |
remove(Fqn fqn,
Object key)
Removes key from the node's hashmap |
void |
remove(String fqn)
Removes the node from the tree. |
Object |
remove(String fqn,
Object key)
Removes key from the node's hashmap |
void |
removeData(Fqn fqn)
|
void |
removeData(String fqn)
|
void |
removeTreeCacheListener(TreeCacheListener listener)
|
void |
setCacheLoader(CacheLoader cache_loader)
|
void |
setCacheLoaderClass(String cache_loader_class)
|
void |
setCacheLoaderConfig(Properties cache_loader_config)
|
void |
setCacheLoaderFetchPersistentState(boolean flag)
|
void |
setCacheLoaderFetchTransientState(boolean flag)
|
void |
setCacheLoaderPreload(String list)
|
void |
setCacheLoaderShared(boolean shared)
|
void |
setCacheMode(String mode)
Sets the default caching mode) |
void |
setClusterConfig(Element config)
Convert a list of elements to the JG property string |
void |
setClusterName(String name)
Set the name of the replication group |
void |
setClusterProperties(String cluster_props)
Set the cluster properties. |
void |
setEvictionPolicyClass(String eviction_policy_class)
Sets the classname of the eviction policy |
void |
setEvictionPolicyConfig(Element config)
Setup eviction policy configuration |
void |
setFetchStateOnStartup(boolean flag)
|
void |
setInitialStateRetrievalTimeout(long timeout)
Set the initial state transfer timeout (see getInitialStateRetrievalTimeout() ) |
void |
setIsolationLevel(String level)
Set the transaction isolation level. |
void |
setJndiName(String jndi_name)
|
void |
setLockAcquisitionTimeout(long timeout)
Set the max time for lock acquisition. |
void |
setReplQueueInterval(long interval)
|
void |
setReplQueueMaxElements(int max_elements)
|
void |
setSyncCommitPhase(boolean sync_commit_phase)
|
void |
setSyncReplTimeout(long timeout)
Sets the default maximum wait time for synchronous replication to receive all results |
void |
setSyncRollbackPhase(boolean sync_rollback_phase)
|
void |
setTransactionManagerLookup(TransactionManagerLookup l)
Sets the TransactionManagerLookup object |
void |
setTransactionManagerLookupClass(String cl)
Sets the class of the TransactionManagerLookup impl. |
void |
setUseReplQueue(boolean flag)
|
void |
startService()
|
void |
stopService()
|
String |
toString()
|
Methods inherited from interface org.jboss.system.ServiceMBean |
getName, getState, getStateString, jbossInternalLifecycle |
Methods inherited from interface org.jboss.system.Service |
create, destroy, start, stop |
Method Detail |
public Object getLocalAddress()
public Vector getMembers()
public boolean isCoordinator()
public String getClusterName()
public void setClusterName(String name)
public String getClusterProperties()
public void setClusterProperties(String cluster_props)
cluster_props
- The properties for the cluster (JGroups)public String dumpTransactionTable()
public String getInterceptorChain()
public List getInterceptors()
public String getCacheLoaderClass()
public void setCacheLoaderClass(String cache_loader_class)
public Properties getCacheLoaderConfig()
public void setCacheLoaderConfig(Properties cache_loader_config)
public CacheLoader getCacheLoader()
public void setCacheLoader(CacheLoader cache_loader)
public boolean getCacheLoaderShared()
public void setCacheLoaderShared(boolean shared)
public void setCacheLoaderPreload(String list)
public String getCacheLoaderPreload()
public void setCacheLoaderFetchPersistentState(boolean flag)
public boolean getCacheLoaderFetchPersistentState()
public void setCacheLoaderFetchTransientState(boolean flag)
public boolean getCacheLoaderFetchTransientState()
public boolean getSyncCommitPhase()
public void setSyncCommitPhase(boolean sync_commit_phase)
public boolean getSyncRollbackPhase()
public void setSyncRollbackPhase(boolean sync_rollback_phase)
public void setEvictionPolicyConfig(Element config)
public void setClusterConfig(Element config)
public long getInitialStateRetrievalTimeout()
public void setInitialStateRetrievalTimeout(long timeout)
getInitialStateRetrievalTimeout()
)
public String getCacheMode()
public void setCacheMode(String mode) throws Exception
Exception
public long getSyncReplTimeout()
public void setSyncReplTimeout(long timeout)
public boolean getUseReplQueue()
public void setUseReplQueue(boolean flag)
public long getReplQueueInterval()
public void setReplQueueInterval(long interval)
public int getReplQueueMaxElements()
public void setReplQueueMaxElements(int max_elements)
public String getIsolationLevel()
public void setIsolationLevel(String level)
public boolean getFetchStateOnStartup()
public void setFetchStateOnStartup(boolean flag)
public long getLockAcquisitionTimeout()
public void setLockAcquisitionTimeout(long timeout)
timeout
- public String getEvictionPolicyClass()
public void setEvictionPolicyClass(String eviction_policy_class)
public int getEvictionThreadWakeupIntervalSeconds()
public void setTransactionManagerLookup(TransactionManagerLookup l)
l
- public String getTransactionManagerLookupClass()
public void setTransactionManagerLookupClass(String cl) throws Exception
cl
-
Exception
public TransactionManager getTransactionManager()
public TreeCache getInstance()
public String getJndiName()
public void setJndiName(String jndi_name) throws Exception
Exception
public void fetchState(long timeout) throws org.jgroups.ChannelClosedException, org.jgroups.ChannelNotConnectedException
org.jgroups.ChannelClosedException
org.jgroups.ChannelNotConnectedException
public void addTreeCacheListener(TreeCacheListener listener)
public void removeTreeCacheListener(TreeCacheListener listener)
public void createService() throws Exception
Exception
public void destroyService()
public void startService() throws Exception
Exception
public void load(String fqn) throws Exception
fqn
-
Exception
public void stopService()
public Set getKeys(String fqn) throws CacheException
CacheException
public Set getKeys(Fqn fqn) throws CacheException
CacheException
public Object get(String fqn, Object key) throws CacheException
data
map. Returns null if the node was not found in the tree or the key was not found in the hashmap.
fqn
- The fully qualified name of the node.key
- The key.
CacheException
public Object get(Fqn fqn, Object key) throws CacheException
data
map. Returns null if the node was not found in the tree or the key was not found in the hashmap.
fqn
- The fully qualified name of the node.key
- The key.
CacheException
public boolean exists(String fqn)
fqn
- The fully qualified name of the node
public boolean exists(Fqn fqn)
fqn
- The fully qualified name of the node
public boolean exists(String fqn, Object key)
public boolean exists(Fqn fqn, Object key)
get(Fqn,Object)
fqn
- The fully qualified name of the nodekey
-
public void put(String fqn, Map data) throws CacheException
fqn
- The fully qualified name of the new nodedata
- The new data. May be null if no data should be set in the node.
CacheException
public void put(Fqn fqn, Map data) throws CacheException
fqn
- The fully qualified name of the new nodedata
- The new data. May be null if no data should be set in the node.
CacheException
public Object put(String fqn, Object key, Object value) throws CacheException
fqn
- The fully qualified name of the nodekey
- The keyvalue
- The value
CacheException
public Object put(Fqn fqn, Object key, Object value) throws CacheException
fqn
- The fully qualified name of the nodekey
- The keyvalue
- The value
CacheException
public void remove(String fqn) throws CacheException
fqn
- The fully qualified name of the node.
CacheException
public void remove(Fqn fqn) throws CacheException
fqn
- The fully qualified name of the node.
CacheException
public void evict(Fqn fqn) throws CacheException
fqn
- Will remove everythign assoicated with this fqn.
CacheException
public void evict(Fqn fqn, Object key) throws CacheException
fqn
- key
-
CacheException
public Object remove(String fqn, Object key) throws CacheException
key
from the node's hashmap
fqn
- The fullly qualified name of the nodekey
- The key to be removed
CacheException
public Object remove(Fqn fqn, Object key) throws CacheException
key
from the node's hashmap
fqn
- The fullly qualified name of the nodekey
- The key to be removed
CacheException
public void removeData(String fqn) throws CacheException
CacheException
public void removeData(Fqn fqn) throws CacheException
CacheException
public void releaseAllLocks(String fqn)
fqn
- public void releaseAllLocks(Fqn fqn)
fqn
- public String print(String fqn)
fqn
. Output includes name, fqn and data.
public String print(Fqn fqn)
fqn
. Output includes name, fqn and data.
public Set getChildrenNames(String fqn) throws CacheException
fqn
- The fully qualified name of the node
CacheException
public Set getChildrenNames(Fqn fqn) throws CacheException
fqn
- The fully qualified name of the node
CacheException
public String toString()
public String printDetails()
public String printLockInfo()
public int getNumberOfLocksHeld()
public int getNumberOfNodes()
public int getNumberOfAttributes()
public List callRemoteMethods(Vector members, Method method, Object[] args, boolean synchronous, boolean exclude_self, long timeout) throws Exception
Exception
public List callRemoteMethods(Vector members, String method_name, Class[] types, Object[] args, boolean synchronous, boolean exclude_self, long timeout) throws Exception
Exception
public void _put(GlobalTransaction tx, String fqn, Map data, boolean create_undo_ops) throws CacheException
TransactionEntry
's lock list, (b) add nodes that were created to TransactionEntry
's node list and (c) create Modification
s and add them to TransactionEntry
's modification list and (d) create compensating modifications to undo the changes in case of a rollback
fqn
- data
- create_undo_ops
- If true, undo operations will be created (default is true). Otherwise they will not be created (used by rollback()).
CacheException
public void _put(GlobalTransaction tx, Fqn fqn, Map data, boolean create_undo_ops) throws CacheException
TransactionEntry
's lock list, (b) add nodes that were created to TransactionEntry
's node list and (c) create Modification
s and add them to TransactionEntry
's modification list and (d) create compensating modifications to undo the changes in case of a rollback
fqn
- data
- create_undo_ops
- If true, undo operations will be created (default is true). Otherwise they will not be created (used by rollback()).
CacheException
public void _put(GlobalTransaction tx, Fqn fqn, Map data, boolean create_undo_ops, boolean erase_contents) throws CacheException
TransactionEntry
's lock list, (b) add nodes that were created to TransactionEntry
's node list and (c) create Modification
s and add them to TransactionEntry
's modification list and (d) create compensating modifications to undo the changes in case of a rollback
fqn
- data
- create_undo_ops
- If true, undo operations will be created (default is true).erase_contents
- Clear the existing hashmap before putting the new data into it Otherwise they will not be created (used by rollback()).
CacheException
public Object _put(GlobalTransaction tx, String fqn, Object key, Object value, boolean create_undo_ops) throws CacheException
CacheException
public Object _put(GlobalTransaction tx, Fqn fqn, Object key, Object value, boolean create_undo_ops) throws CacheException
CacheException
public void _remove(GlobalTransaction tx, String fqn, boolean create_undo_ops) throws CacheException
CacheException
public void _remove(GlobalTransaction tx, Fqn fqn, boolean create_undo_ops) throws CacheException
CacheException
public Object _remove(GlobalTransaction tx, String fqn, Object key, boolean create_undo_ops) throws CacheException
CacheException
public Object _remove(GlobalTransaction tx, Fqn fqn, Object key, boolean create_undo_ops) throws CacheException
CacheException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |