org.apache.catalina.ha.session
public class BackupManager extends StandardManager implements ClusterManager, AbstractReplicatedMap.MapOwner
ManagerBase.SessionTiming| Modifier and Type | Field and Description |
|---|---|
protected CatalinaCluster |
cluster
A reference to the cluster
|
protected static long |
DEFAULT_REPL_TIMEOUT |
static Log |
log |
protected boolean |
mExpireSessionsOnShutdown
Set to true if we don't want the sessions to expire on shutdown
|
protected java.lang.String |
name
The name of this manager
|
info, lifecycle, maxActiveSessions, pathname, processingTime, rejectedSessions, startedalgorithm, container, DEFAULT_ALGORITHM, devRandomSource, digest, distributable, domain, duplicates, entropy, expiredSessions, initialized, maxActive, maxInactiveInterval, mserver, oname, processExpiresFrequency, random, randomClass, randomIS, sessionAverageAliveTime, sessionCounter, sessionCreationTiming, sessionExpirationTiming, sessionIdLength, sessionMaxAliveTime, sessions, sm, support, TIMING_STATS_CACHE_SIZEAFTER_START_EVENT, AFTER_STOP_EVENT, BEFORE_START_EVENT, BEFORE_STOP_EVENT, DESTROY_EVENT, INIT_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.
|
boolean |
doDomainReplication() |
int |
getActiveSessionsFull() |
java.lang.ClassLoader[] |
getClassLoaders() |
CatalinaCluster |
getCluster() |
boolean |
getDistributable()
Return the distributable flag for the sessions supported by
this Manager.
|
boolean |
getExpireSessionsOnShutdown() |
java.lang.String[] |
getInvalidatedSessions()
When the manager expires session not tied to a request.
|
java.lang.String |
getMapName() |
int |
getMapSendOptions() |
java.lang.String |
getName()
Return the descriptive short name of this Manager implementation.
|
ReplicationStream |
getReplicationStream(byte[] data)
Open Stream and use correct ClassLoader (Container) Switch
ThreadClassLoader
|
ReplicationStream |
getReplicationStream(byte[] data,
int offset,
int length) |
boolean |
isDefaultMode() |
boolean |
isNotifyListenersOnReplication() |
java.lang.String |
listSessionIdsFull() |
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(java.lang.Object key,
java.lang.Object value) |
ClusterMessage |
requestCompleted(java.lang.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 |
setCluster(CatalinaCluster cluster) |
void |
setDefaultMode(boolean defaultMode) |
void |
setDistributable(boolean dist)
Set the distributable flag for the sessions supported by this
Manager.
|
void |
setDomainReplication(boolean sendClusterDomainOnly) |
void |
setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown) |
void |
setMapSendOptions(int mapSendOptions) |
void |
setName(java.lang.String name)
Set the name of the manager, at host /context name and at engine hostname+/context
|
void |
setNotifyListenersOnReplication(boolean notifyListenersOnReplication) |
void |
start()
Prepare for the beginning of active use of the public methods of this
component.
|
void |
stop()
Gracefully terminate the active use of the public methods of this
component.
|
void |
unload()
Override persistence since they don't go hand in hand with replication for now.
|
addLifecycleListener, createSession, doLoad, doUnload, file, findLifecycleListeners, getInfo, getMaxActiveSessions, getPathname, getRejectedSessions, load, propertyChange, removeLifecycleListener, setContainer, setMaxActiveSessions, setPathname, setRejectedSessionsadd, addPropertyChangeListener, backgroundProcess, changeSessionId, createSession, destroy, expireSession, findSession, findSessions, generateSessionId, getActiveSessions, getAlgorithm, getClassName, getContainer, getCreationTime, getCreationTimestamp, getDigest, getDomain, getDuplicates, getEngine, getEntropy, getExpiredSessions, getJvmRoute, getLastAccessedTime, getLastAccessedTimestamp, getMaxActive, getMaxInactiveInterval, getNewSession, getObjectName, getProcessExpiresFrequency, getProcessingTime, getRandom, getRandomBytes, getRandomClass, getRandomFile, getSession, getSessionAttribute, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdLength, getSessionMaxAliveTime, init, listSessionIds, postDeregister, postRegister, preDeregister, preRegister, processExpires, remove, removePropertyChangeListener, setAlgorithm, setDuplicates, setEntropy, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setProcessExpiresFrequency, setProcessingTime, setRandomClass, setRandomFile, setSessionAverageAliveTime, setSessionCounter, setSessionIdLength, setSessionMaxAliveTimeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitadd, addPropertyChangeListener, backgroundProcess, changeSessionId, createSession, createSession, findSession, findSessions, getActiveSessions, getContainer, getExpiredSessions, getInfo, getMaxActive, getMaxInactiveInterval, getRejectedSessions, getSessionAverageAliveTime, getSessionCounter, getSessionIdLength, getSessionMaxAliveTime, load, remove, removePropertyChangeListener, setContainer, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setRejectedSessions, setSessionAverageAliveTime, setSessionCounter, setSessionIdLength, setSessionMaxAliveTimepublic static Log log
protected static long DEFAULT_REPL_TIMEOUT
protected boolean mExpireSessionsOnShutdown
protected java.lang.String name
protected CatalinaCluster cluster
public void messageDataReceived(ClusterMessage msg)
ClusterManagermessageDataReceived in interface ClusterManagermsg - - the message received.public boolean doDomainReplication()
doDomainReplication in interface ClusterManagerpublic void setDomainReplication(boolean sendClusterDomainOnly)
setDomainReplication in interface ClusterManagersendClusterDomainOnly - The sendClusterDomainOnly to set.public boolean isDefaultMode()
isDefaultMode in interface ClusterManagerpublic void setDefaultMode(boolean defaultMode)
setDefaultMode in interface ClusterManagerdefaultMode - The defaultMode to set.public void setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)
public void setCluster(CatalinaCluster cluster)
setCluster in interface ClusterManagerpublic boolean getExpireSessionsOnShutdown()
public void unload()
throws java.io.IOException
unload in interface Managerunload in class StandardManagerjava.io.IOException - if an input/output error occurspublic ClusterMessage requestCompleted(java.lang.String sessionId)
ClusterManagerrequestCompleted in interface ClusterManagersessionId - - the sessionId that just completed.public void objectMadePrimay(java.lang.Object key,
java.lang.Object value)
objectMadePrimay in interface AbstractReplicatedMap.MapOwnerpublic Session createEmptySession()
ManagerBasecreateEmptySession in interface ManagercreateEmptySession in class ManagerBasepublic java.lang.ClassLoader[] getClassLoaders()
public ReplicationStream getReplicationStream(byte[] data) throws java.io.IOException
getReplicationStream in interface ClusterManagerdata - java.io.IOExceptionpublic ReplicationStream getReplicationStream(byte[] data, int offset, int length) throws java.io.IOException
getReplicationStream in interface ClusterManagerjava.io.IOExceptionpublic java.lang.String getName()
StandardManagergetName in interface ClusterManagergetName in class StandardManagerpublic void start()
throws LifecycleException
configure(),
and before any of the public methods of the component are utilized.start in interface Lifecyclestart in class StandardManagerjava.lang.IllegalStateException - if this component has already been
startedLifecycleException - if this component detects a fatal error
that prevents this component from being usedpublic java.lang.String getMapName()
public void stop()
throws LifecycleException
stop in interface Lifecyclestop in class StandardManagerjava.lang.IllegalStateException - if this component has not been startedLifecycleException - if this component detects a fatal error
that needs to be reportedpublic void setDistributable(boolean dist)
ManagerBasesetDistributable in interface ManagersetDistributable in class ManagerBasedist - The new distributable flagpublic boolean getDistributable()
ManagerBasegetDistributable in interface ManagergetDistributable in class ManagerBasepublic void setName(java.lang.String name)
ClusterManagersetName in interface ClusterManagerpublic boolean isNotifyListenersOnReplication()
isNotifyListenersOnReplication in interface ClusterManagerpublic void setNotifyListenersOnReplication(boolean notifyListenersOnReplication)
public void setMapSendOptions(int mapSendOptions)
public CatalinaCluster getCluster()
getCluster in interface ClusterManagerpublic int getMapSendOptions()
public java.lang.String[] getInvalidatedSessions()
ClusterManagergetInvalidatedSessions in interface ClusterManagerpublic ClusterManager cloneFromTemplate()
cloneFromTemplate in interface ClusterManagerpublic int getActiveSessionsFull()
public java.lang.String listSessionIdsFull()
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.