javax.management.MBeanRegistration
, ClusterManager
, JmxEnabled
, Lifecycle
, Manager
BackupManager
, DeltaManager
public abstract class ClusterManagerBase extends ManagerBase implements ClusterManager
Lifecycle.SingleUse
ManagerBase.SessionTiming
Modifier and Type | Field | Description |
---|---|---|
protected CatalinaCluster |
cluster |
A reference to the cluster
|
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
mserver
duplicates, expiredSessions, maxActive, maxActiveSessions, processExpiresFrequency, processingTime, rejectedSessions, secureRandomAlgorithm, secureRandomClass, secureRandomProvider, sessionCounter, sessionCreationTiming, sessionExpirationTiming, sessionIdGenerator, sessionIdGeneratorClass, sessionMaxAliveTime, sessions, sm, support, TIMING_STATS_CACHE_SIZE
Constructor | Description |
---|---|
ClusterManagerBase() |
Modifier and Type | Method | Description |
---|---|---|
protected void |
clone(ClusterManagerBase copy) |
|
java.lang.ClassLoader[] |
getClassLoaders() |
|
static java.lang.ClassLoader[] |
getClassLoaders(Context context) |
|
CatalinaCluster |
getCluster() |
|
ReplicationStream |
getReplicationStream(byte[] data) |
Open stream and use correct ClassLoader (Container), switching thread
context class loader.
|
ReplicationStream |
getReplicationStream(byte[] data,
int offset,
int length) |
|
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) |
|
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. |
cloneFromTemplate, getInvalidatedSessions, getName, messageDataReceived, requestCompleted, setName
addLifecycleListener, destroy, findLifecycleListeners, fireLifecycleEvent, getState, getStateName, getThrowOnFailure, init, removeLifecycleListener, setState, setState, setThrowOnFailure, start, stop
destroyInternal, getDomain, getObjectName, postDeregister, postRegister, preDeregister, preRegister, register, setDomain, unregister
add, addPropertyChangeListener, backgroundProcess, changeSessionId, changeSessionId, createEmptySession, createSession, findSession, findSessions, getActiveSessions, getContext, getExpiredSessions, getMaxActive, getNotifyAttributeListenerOnUnchangedValue, getNotifyBindingListenerOnUnchangedValue, getRejectedSessions, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionMaxAliveTime, remove, remove, removePropertyChangeListener, setContext, setExpiredSessions, setMaxActive, setNotifyAttributeListenerOnUnchangedValue, setNotifyBindingListenerOnUnchangedValue, setSessionCounter, setSessionIdGenerator, setSessionMaxAliveTime, willAttributeDistribute
add, addPropertyChangeListener, backgroundProcess, changeSessionId, changeSessionId, changeSessionId, createEmptySession, createSession, expireSession, findSession, findSessions, generateSessionId, getActiveSessions, getClassName, getContext, getCreationTime, getCreationTimestamp, getDomainInternal, getDuplicates, getEngine, getExpiredSessions, getJvmRoute, getLastAccessedTime, getLastAccessedTimestamp, getMaxActive, getMaxActiveSessions, getName, getNewSession, getNotifyAttributeListenerOnUnchangedValue, getNotifyBindingListenerOnUnchangedValue, getObjectNameKeyProperties, getProcessExpiresFrequency, getProcessingTime, getRejectedSessions, getSecureRandomAlgorithm, getSecureRandomClass, getSecureRandomProvider, getSession, getSessionAttribute, getSessionAttributeNameFilter, getSessionAttributeNamePattern, getSessionAttributeValueClassNameFilter, getSessionAttributeValueClassNamePattern, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionMaxAliveTime, getThisAccessedTime, getThisAccessedTimestamp, getWarnOnSessionAttributeFilterFailure, initInternal, listSessionIds, processExpires, remove, remove, removePropertyChangeListener, setContext, setDuplicates, setExpiredSessions, setMaxActive, setMaxActiveSessions, setNotifyAttributeListenerOnUnchangedValue, setNotifyBindingListenerOnUnchangedValue, setProcessExpiresFrequency, setProcessingTime, setSecureRandomAlgorithm, setSecureRandomClass, setSecureRandomProvider, setSessionAttributeNameFilter, setSessionAttributeValueClassNameFilter, setSessionCounter, setSessionIdGenerator, setSessionMaxAliveTime, setWarnOnSessionAttributeFilterFailure, toString, updateSessionMaxAliveTime, willAttributeDistribute
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 boolean isRecordAllActions()
public void setRecordAllActions(boolean recordAllActions)
public static java.lang.ClassLoader[] getClassLoaders(Context context)
public java.lang.ClassLoader[] getClassLoaders()
public ReplicationStream getReplicationStream(byte[] data) throws java.io.IOException
ClusterManager
getReplicationStream
in interface ClusterManager
data
- The datajava.io.IOException
- An error occurredpublic ReplicationStream getReplicationStream(byte[] data, int offset, int length) throws java.io.IOException
getReplicationStream
in interface ClusterManager
java.io.IOException
public 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
LifecycleBase
LifecycleState.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 ManagerBase
LifecycleException
- Start error occurredprotected void stopInternal() throws LifecycleException
LifecycleBase
LifecycleState.STOPPING
during the execution of this method.
Changing state will trigger the Lifecycle.STOP_EVENT
event.stopInternal
in class ManagerBase
LifecycleException
- Stop error occurredCopyright © 2000-2018 Apache Software Foundation. All Rights Reserved.