public class BackupManager extends ClusterManagerBase implements AbstractReplicatedMap.MapOwner, DistributedManager
ManagerBase.SessionTiming
Lifecycle.SingleUse
Modifier and Type | Field and Description |
---|---|
protected static long |
DEFAULT_REPL_TIMEOUT |
protected boolean |
mExpireSessionsOnShutdown
Deprecated.
Unused - will be removed in Tomcat 8.0.x
|
protected String |
name
The name of this manager
|
protected static StringManager |
sm
The string manager for this package.
|
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, 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 |
---|
BackupManager()
Constructor, just calls super()
|
Modifier and Type | Method and Description |
---|---|
ClusterManager |
cloneFromTemplate() |
Session |
createEmptySession()
Get a session from the recycled ones or create a new empty one.
|
long |
getAccessTimeout() |
int |
getActiveSessionsFull()
Returns the total session count for primary, backup and proxy.
|
boolean |
getExpireSessionsOnShutdown()
Deprecated.
Unused - will be removed in Tomcat 8.0.x
|
String[] |
getInvalidatedSessions()
When the manager expires session not tied to a request.
|
String |
getMapName() |
int |
getMapSendOptions() |
String |
getName()
Return the name of the manager, at host /context name and at engine hostname+/context.
|
long |
getRpcTimeout() |
Set<String> |
getSessionIdsFull()
Returns the list of all sessions IDS (primary, backup and proxy).
|
boolean |
isTerminateOnStartFailure() |
void |
messageDataReceived(ClusterMessage msg)
A message was received from another node, this
is the callback method to implement if you are interested in
receiving replication messages.
|
void |
objectMadePrimay(Object key,
Object value) |
ClusterMessage |
requestCompleted(String sessionId)
When the request has been completed, the replication valve
will notify the manager, and the manager will decide whether
any replication is needed or not.
|
void |
setAccessTimeout(long accessTimeout) |
void |
setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)
Deprecated.
Unused - will be removed in Tomcat 8.0.x
|
void |
setMapSendOptions(int mapSendOptions) |
void |
setName(String name)
Set the name of the manager, at host /context name and at engine hostname+/context
|
void |
setRpcTimeout(long rpcTimeout) |
void |
setTerminateOnStartFailure(boolean terminateOnStartFailure) |
protected void |
startInternal()
Start this component and implement the requirements
of
LifecycleBase.startInternal() . |
protected void |
stopInternal()
Stop this component and implement the requirements
of
LifecycleBase.stopInternal() . |
clone, getClassLoaders, getClassLoaders, getCluster, getDeltaRequestPool, getReplicationStream, getReplicationStream, getSessionAttributeFilter, isNotifyListenersOnReplication, isRecordAllActions, load, registerSessionAtReplicationValve, setCluster, setNotifyListenersOnReplication, setRecordAllActions, setSessionAttributeFilter, unload, willAttributeDistribute
add, addPropertyChangeListener, backgroundProcess, changeSessionId, changeSessionId, createSession, expireSession, findSession, findSessions, generateSessionId, getActiveSessions, getClassName, getContainer, getCreationTime, getCreationTimestamp, getDistributable, getDomainInternal, getDuplicates, getEngine, getExpiredSessions, getInfo, getJvmRoute, getLastAccessedTime, getLastAccessedTimestamp, getMaxActive, getMaxActiveSessions, getMaxInactiveInterval, 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, willAttributeDistribute
destroyInternal, getDomain, getObjectName, postDeregister, postRegister, preDeregister, preRegister, register, setDomain, unregister
addLifecycleListener, destroy, findLifecycleListeners, fireLifecycleEvent, getState, getStateName, getThrowOnFailure, init, removeLifecycleListener, setState, setState, setThrowOnFailure, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, addPropertyChangeListener, backgroundProcess, changeSessionId, 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, willAttributeDistribute
protected static final StringManager sm
protected static long DEFAULT_REPL_TIMEOUT
@Deprecated protected boolean mExpireSessionsOnShutdown
protected String name
public void messageDataReceived(ClusterMessage msg)
ClusterManager
messageDataReceived
in interface ClusterManager
msg
- - the message received.@Deprecated public void setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)
@Deprecated public boolean getExpireSessionsOnShutdown()
public ClusterMessage requestCompleted(String sessionId)
ClusterManager
requestCompleted
in interface ClusterManager
sessionId
- - the sessionId that just completed.public void objectMadePrimay(Object key, Object value)
objectMadePrimay
in interface AbstractReplicatedMap.MapOwner
public Session createEmptySession()
Manager
createEmptySession
in interface Manager
createEmptySession
in class ManagerBase
public String getName()
ClusterManager
getName
in interface ClusterManager
getName
in class ManagerBase
protected void startInternal() throws LifecycleException
LifecycleBase.startInternal()
.
Starts the cluster communication channel, this will connect with the
other nodes in the cluster, and request the current session state to be
transferred to this node.startInternal
in class ClusterManagerBase
LifecycleException
- if this component detects a fatal error
that prevents this component from being usedpublic String getMapName()
protected void stopInternal() throws LifecycleException
LifecycleBase.stopInternal()
.
This will disconnect the cluster communication channel and stop the
listener thread.stopInternal
in class ClusterManagerBase
LifecycleException
- if this component detects a fatal error
that prevents this component from being usedpublic void setName(String name)
ClusterManager
setName
in interface ClusterManager
public void setMapSendOptions(int mapSendOptions)
public int getMapSendOptions()
public void setRpcTimeout(long rpcTimeout)
public long getRpcTimeout()
public void setTerminateOnStartFailure(boolean terminateOnStartFailure)
public boolean isTerminateOnStartFailure()
public long getAccessTimeout()
public void setAccessTimeout(long accessTimeout)
public String[] getInvalidatedSessions()
ClusterManager
getInvalidatedSessions
in interface ClusterManager
public ClusterManager cloneFromTemplate()
cloneFromTemplate
in interface ClusterManager
public int getActiveSessionsFull()
DistributedManager
getActiveSessionsFull
in interface DistributedManager
public Set<String> getSessionIdsFull()
DistributedManager
getSessionIdsFull
in interface DistributedManager
Copyright © 2000-2021 Apache Software Foundation. All Rights Reserved.