public abstract class ClusterManagerBase extends ManagerBase implements ClusterManager
ManagerBase.SessionTiming
Modifier and Type | Field and Description |
---|---|
protected CatalinaCluster |
cluster
A reference to the cluster
|
container, distributable, duplicates, expiredSessions, maxActive, maxActiveSessions, maxInactiveInterval, processExpiresFrequency, processingTime, rejectedSessions, secureRandomAlgorithm, secureRandomClass, secureRandomProvider, sessionCounter, sessionCreationTiming, sessionExpirationTiming, sessionIdGenerator, sessionIdLength, sessionMaxAliveTime, sessions, sm, support, TIMING_STATS_CACHE_SIZE
mserver
AFTER_DESTROY_EVENT, AFTER_INIT_EVENT, AFTER_START_EVENT, AFTER_STOP_EVENT, BEFORE_DESTROY_EVENT, BEFORE_INIT_EVENT, BEFORE_START_EVENT, BEFORE_STOP_EVENT, CONFIGURE_START_EVENT, CONFIGURE_STOP_EVENT, PERIODIC_EVENT, START_EVENT, STOP_EVENT
Constructor and Description |
---|
ClusterManagerBase() |
Modifier and Type | Method and Description |
---|---|
protected void |
clone(ClusterManagerBase copy) |
ClassLoader[] |
getClassLoaders() |
static ClassLoader[] |
getClassLoaders(Container container) |
CatalinaCluster |
getCluster() |
ReplicationStream |
getReplicationStream(byte[] data)
Open Stream and use correct ClassLoader (Container) Switch
ThreadClassLoader
|
ReplicationStream |
getReplicationStream(byte[] data,
int offset,
int length) |
String |
getSessionAttributeFilter()
Return the string pattern used for including session attributes
to replication.
|
boolean |
isNotifyListenersOnReplication() |
void |
load()
Manager implementations that also implement
ClusterManager do not support local session persistence. |
void |
setCluster(CatalinaCluster cluster) |
void |
setNotifyListenersOnReplication(boolean notifyListenersOnReplication) |
void |
setSessionAttributeFilter(String sessionAttributeFilter)
Set the pattern used for including session attributes to replication.
|
void |
unload()
Save any currently active sessions in the appropriate persistence
mechanism, if any.
|
boolean |
willAttributeDistribute(String name)
Check whether the given session attribute should be distributed
|
add, addPropertyChangeListener, backgroundProcess, changeSessionId, createEmptySession, createSession, expireSession, findSession, findSessions, generateSessionId, getActiveSessions, getClassName, getContainer, getCreationTime, getCreationTimestamp, getDistributable, getDomainInternal, getDuplicates, getEngine, getExpiredSessions, getInfo, getJvmRoute, getLastAccessedTime, getLastAccessedTimestamp, getMaxActive, getMaxActiveSessions, getMaxInactiveInterval, getName, getNewSession, getObjectNameKeyProperties, getProcessExpiresFrequency, getProcessingTime, getRejectedSessions, getSecureRandomAlgorithm, getSecureRandomClass, getSecureRandomProvider, getSession, getSessionAttribute, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdLength, getSessionMaxAliveTime, getThisAccessedTime, getThisAccessedTimestamp, initInternal, listSessionIds, processExpires, propertyChange, remove, remove, removePropertyChangeListener, setContainer, setDistributable, setDuplicates, setExpiredSessions, setMaxActive, setMaxActiveSessions, setMaxInactiveInterval, setProcessExpiresFrequency, setProcessingTime, setSecureRandomAlgorithm, setSecureRandomClass, setSecureRandomProvider, setSessionCounter, setSessionIdLength, setSessionMaxAliveTime, startInternal, stopInternal, toString, updateSessionMaxAliveTime
destroyInternal, getDomain, getObjectName, postDeregister, postRegister, preDeregister, preRegister, register, setDomain, unregister
addLifecycleListener, destroy, findLifecycleListeners, fireLifecycleEvent, getState, getStateName, init, removeLifecycleListener, setState, setState, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
cloneFromTemplate, getInvalidatedSessions, getName, messageDataReceived, requestCompleted, setName
add, addPropertyChangeListener, backgroundProcess, changeSessionId, createEmptySession, createSession, findSession, findSessions, getActiveSessions, getContainer, getDistributable, getExpiredSessions, getInfo, getMaxActive, getMaxInactiveInterval, getRejectedSessions, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdLength, getSessionMaxAliveTime, remove, remove, removePropertyChangeListener, setContainer, setDistributable, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setSessionCounter, setSessionIdLength, setSessionMaxAliveTime
protected CatalinaCluster cluster
public CatalinaCluster getCluster()
getCluster
in interface ClusterManager
public void setCluster(CatalinaCluster cluster)
setCluster
in interface ClusterManager
public boolean isNotifyListenersOnReplication()
isNotifyListenersOnReplication
in interface ClusterManager
public void setNotifyListenersOnReplication(boolean notifyListenersOnReplication)
public String getSessionAttributeFilter()
public void setSessionAttributeFilter(String sessionAttributeFilter)
E.g. ^(userName|sessionHistory)$
sessionAttributeFilter
- the filter name pattern to setpublic boolean willAttributeDistribute(String name)
public static ClassLoader[] getClassLoaders(Container container)
public ClassLoader[] getClassLoaders()
public ReplicationStream getReplicationStream(byte[] data) throws IOException
getReplicationStream
in interface ClusterManager
data
- IOException
public ReplicationStream getReplicationStream(byte[] data, int offset, int length) throws IOException
getReplicationStream
in interface ClusterManager
IOException
public void load()
Manager
implementations that also implement
ClusterManager
do not support local session persistence.public void unload()
Manager
protected void clone(ClusterManagerBase copy)
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.