public abstract class ClusterManagerBase extends ManagerBase implements ClusterManager
ManagerBase.SessionTimingLifecycle.SingleUse| 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, SESSION_ID_LENGTH_UNSET, sessionCounter, sessionCreationTiming, sessionExpirationTiming, sessionIdGenerator, sessionIdGeneratorClass, sessionIdLength, sessionMaxAliveTime, sessions, sm, support, TIMING_STATS_CACHE_SIZEmserverAFTER_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() |
protected SynchronizedStack<DeltaRequest> |
getDeltaRequestPool() |
ReplicationStream |
getReplicationStream(byte[] data)
Open stream and use correct ClassLoader (Container), switching thread
context class loader.
|
ReplicationStream |
getReplicationStream(byte[] data,
int offset,
int length) |
String |
getSessionAttributeFilter()
Deprecated.
Use
ManagerBase.getSessionAttributeNameFilter(). Will be removed
in Tomcat 9.0.x |
boolean |
isNotifyListenersOnReplication() |
boolean |
isRecordAllActions() |
void |
load()
Manager implementations that also implement
ClusterManager do not support local session persistence. |
protected void |
registerSessionAtReplicationValve(DeltaSession session)
Register cross context session at replication valve thread local
|
void |
setCluster(CatalinaCluster cluster) |
void |
setNotifyListenersOnReplication(boolean notifyListenersOnReplication) |
void |
setRecordAllActions(boolean recordAllActions) |
void |
setSessionAttributeFilter(String sessionAttributeFilter)
Deprecated.
Use
ManagerBase.setSessionAttributeNameFilter(String). Will be
removed in Tomcat 9.0.x |
protected void |
startInternal()
Sub-classes must ensure that the state is changed to
LifecycleState.STARTING during the execution of this method. |
protected void |
stopInternal()
Sub-classes must ensure that the state is changed to
LifecycleState.STOPPING during the execution of this method. |
void |
unload()
Manager implementations that also implement
ClusterManager do not support local session persistence. |
boolean |
willAttributeDistribute(String name)
Deprecated.
Use
ManagerBase.willAttributeDistribute(String, Object). Will be
removed in Tomcat 9.0.x |
add, addPropertyChangeListener, backgroundProcess, changeSessionId, 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, getPersistAuthentication, getProcessExpiresFrequency, getProcessingTime, getRejectedSessions, getSecureRandomAlgorithm, getSecureRandomClass, getSecureRandomProvider, getSession, getSessionAttribute, getSessionAttributeNameFilter, getSessionAttributeNamePattern, getSessionAttributeValueClassNameFilter, getSessionAttributeValueClassNamePattern, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionIdLength, getSessionMaxAliveTime, getThisAccessedTime, getThisAccessedTimestamp, getWarnOnSessionAttributeFilterFailure, initInternal, listSessionIds, processExpires, remove, remove, removePropertyChangeListener, rotateSessionId, setContainer, setDistributable, setDuplicates, setExpiredSessions, setMaxActive, setMaxActiveSessions, setMaxInactiveInterval, setPersistAuthentication, setProcessExpiresFrequency, setProcessingTime, setSecureRandomAlgorithm, setSecureRandomClass, setSecureRandomProvider, setSessionAttributeNameFilter, setSessionAttributeValueClassNameFilter, setSessionCounter, setSessionIdGenerator, setSessionIdLength, setSessionMaxAliveTime, setWarnOnSessionAttributeFilterFailure, toString, updateSessionMaxAliveTime, willAttributeDistributedestroyInternal, getDomain, getObjectName, postDeregister, postRegister, preDeregister, preRegister, register, setDomain, unregisteraddLifecycleListener, destroy, findLifecycleListeners, fireLifecycleEvent, getState, getStateName, getThrowOnFailure, init, removeLifecycleListener, setState, setState, setThrowOnFailure, start, stopclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitcloneFromTemplate, getInvalidatedSessions, getName, messageDataReceived, requestCompleted, setNameadd, 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, willAttributeDistributeprotected CatalinaCluster cluster
protected SynchronizedStack<DeltaRequest> getDeltaRequestPool()
public CatalinaCluster getCluster()
getCluster in interface ClusterManagerpublic void setCluster(CatalinaCluster cluster)
setCluster in interface ClusterManagerpublic boolean isNotifyListenersOnReplication()
isNotifyListenersOnReplication in interface ClusterManagerpublic void setNotifyListenersOnReplication(boolean notifyListenersOnReplication)
@Deprecated public String getSessionAttributeFilter()
ManagerBase.getSessionAttributeNameFilter(). Will be removed
in Tomcat 9.0.x@Deprecated public void setSessionAttributeFilter(String sessionAttributeFilter)
ManagerBase.setSessionAttributeNameFilter(String). Will be
removed in Tomcat 9.0.x
E.g. ^(userName|sessionHistory)$
sessionAttributeFilter - the filter name pattern to setpublic boolean isRecordAllActions()
public void setRecordAllActions(boolean recordAllActions)
@Deprecated public boolean willAttributeDistribute(String name)
ManagerBase.willAttributeDistribute(String, Object). Will be
removed in Tomcat 9.0.xpublic static ClassLoader[] getClassLoaders(Container container)
public ClassLoader[] getClassLoaders()
public ReplicationStream getReplicationStream(byte[] data) throws IOException
ClusterManagergetReplicationStream in interface ClusterManagerdata - The dataIOException - An error occurredpublic ReplicationStream getReplicationStream(byte[] data, int offset, int length) throws IOException
getReplicationStream in interface ClusterManagerIOExceptionpublic void load()
Manager implementations that also implement
ClusterManager do not support local session persistence.public void unload()
Manager implementations that also implement
ClusterManager do not support local session persistence.protected void clone(ClusterManagerBase copy)
protected void registerSessionAtReplicationValve(DeltaSession session)
session - cross context sessionprotected void startInternal()
throws LifecycleException
LifecycleBaseLifecycleState.STARTING during the execution of this method.
Changing state will trigger the Lifecycle.START_EVENT event.
If a component fails to start it may either throw a
LifecycleException which will cause it's parent to fail to start
or it can place itself in the error state in which case LifecycleBase.stop()
will be called on the failed component but the parent component will
continue to start normally.startInternal in class ManagerBaseLifecycleException - Start error occurredprotected void stopInternal()
throws LifecycleException
LifecycleBaseLifecycleState.STOPPING during the execution of this method.
Changing state will trigger the Lifecycle.STOP_EVENT event.stopInternal in class ManagerBaseLifecycleException - Stop error occurredCopyright © 2000-2021 Apache Software Foundation. All Rights Reserved.