org.apache.catalina.ha.session
public class BackupManager extends StandardManager implements ClusterManager, AbstractReplicatedMap.MapOwner
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, started
algorithm, container, DEFAULT_ALGORITHM, devRandomSource, digest, distributable, domain, duplicates, entropy, expiredSessions, initialized, maxActive, maxInactiveInterval, mserver, oname, processExpiresFrequency, random, randomClass, randomIS, sessionAverageAliveTime, sessionCounter, sessionIdLength, sessionMaxAliveTime, sessions, sm, support
AFTER_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, setRejectedSessions
add, 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, getSessionIdLength, getSessionMaxAliveTime, init, listSessionIds, postDeregister, postRegister, preDeregister, preRegister, processExpires, remove, removePropertyChangeListener, setAlgorithm, setDuplicates, setEntropy, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setProcessExpiresFrequency, setProcessingTime, setRandomClass, setRandomFile, setSessionAverageAliveTime, setSessionCounter, setSessionIdLength, setSessionMaxAliveTime
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
add, 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, setSessionMaxAliveTime
public 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)
ClusterManager
messageDataReceived
in interface ClusterManager
msg
- - the message received.public boolean doDomainReplication()
doDomainReplication
in interface ClusterManager
public void setDomainReplication(boolean sendClusterDomainOnly)
setDomainReplication
in interface ClusterManager
sendClusterDomainOnly
- The sendClusterDomainOnly to set.public boolean isDefaultMode()
isDefaultMode
in interface ClusterManager
public void setDefaultMode(boolean defaultMode)
setDefaultMode
in interface ClusterManager
defaultMode
- The defaultMode to set.public void setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)
public void setCluster(CatalinaCluster cluster)
setCluster
in interface ClusterManager
public boolean getExpireSessionsOnShutdown()
public void unload() throws java.io.IOException
unload
in interface Manager
unload
in class StandardManager
java.io.IOException
- if an input/output error occurspublic ClusterMessage requestCompleted(java.lang.String sessionId)
ClusterManager
requestCompleted
in interface ClusterManager
sessionId
- - the sessionId that just completed.public void objectMadePrimay(java.lang.Object key, java.lang.Object value)
objectMadePrimay
in interface AbstractReplicatedMap.MapOwner
public Session createEmptySession()
ManagerBase
createEmptySession
in interface Manager
createEmptySession
in class ManagerBase
public java.lang.ClassLoader[] getClassLoaders()
public ReplicationStream getReplicationStream(byte[] data) throws java.io.IOException
getReplicationStream
in interface ClusterManager
data
- java.io.IOException
public ReplicationStream getReplicationStream(byte[] data, int offset, int length) throws java.io.IOException
getReplicationStream
in interface ClusterManager
java.io.IOException
public java.lang.String getName()
StandardManager
getName
in interface ClusterManager
getName
in class StandardManager
public void start() throws LifecycleException
configure()
,
and before any of the public methods of the component are utilized.start
in interface Lifecycle
start
in class StandardManager
java.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 Lifecycle
stop
in class StandardManager
java.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)
ManagerBase
setDistributable
in interface Manager
setDistributable
in class ManagerBase
dist
- The new distributable flagpublic boolean getDistributable()
ManagerBase
getDistributable
in interface Manager
getDistributable
in class ManagerBase
public void setName(java.lang.String name)
ClusterManager
setName
in interface ClusterManager
public boolean isNotifyListenersOnReplication()
isNotifyListenersOnReplication
in interface ClusterManager
public void setNotifyListenersOnReplication(boolean notifyListenersOnReplication)
public void setMapSendOptions(int mapSendOptions)
public CatalinaCluster getCluster()
getCluster
in interface ClusterManager
public int getMapSendOptions()
public java.lang.String[] getInvalidatedSessions()
ClusterManager
getInvalidatedSessions
in interface ClusterManager
public ClusterManager cloneFromTemplate()
cloneFromTemplate
in interface ClusterManager
public int getActiveSessionsFull()
public java.lang.String listSessionIdsFull()
Copyright © 2000-2013 Apache Software Foundation. All Rights Reserved.