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 java.lang.String |
name
The name of this manager
|
protected static StringManager |
sm
The string manager for this package.
|
cluster
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.
|
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 name of the manager, at host /context name and at engine hostname+/context.
|
long |
getRpcTimeout() |
java.util.Set<java.lang.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 |
objectMadePrimary(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 |
setAccessTimeout(long accessTimeout) |
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 |
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, getReplicationStream, getReplicationStream, getSessionAttributeFilter, isNotifyListenersOnReplication, isRecordAllActions, load, registerSessionAtReplicationValve, setCluster, setNotifyListenersOnReplication, setRecordAllActions, setSessionAttributeFilter, unload, willAttributeDistribute
add, addPropertyChangeListener, backgroundProcess, changeSessionId, changeSessionId, changeSessionId, createSession, expireSession, findSession, findSessions, generateSessionId, getActiveSessions, getClassName, getContainer, getContext, getCreationTime, getCreationTimestamp, getDistributable, getDomainInternal, getDuplicates, getEngine, getExpiredSessions, getJvmRoute, getLastAccessedTime, getLastAccessedTimestamp, getMaxActive, getMaxActiveSessions, getMaxInactiveInterval, getNewSession, getObjectNameKeyProperties, 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, setContainer, setContext, setDistributable, setDuplicates, setExpiredSessions, setMaxActive, setMaxActiveSessions, setMaxInactiveInterval, 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, init, removeLifecycleListener, setState, setState, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, addPropertyChangeListener, backgroundProcess, changeSessionId, changeSessionId, createSession, findSession, findSessions, getActiveSessions, getContainer, getContext, getDistributable, getExpiredSessions, getMaxActive, getMaxInactiveInterval, getRejectedSessions, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionIdLength, getSessionMaxAliveTime, remove, remove, removePropertyChangeListener, setContainer, setContext, setDistributable, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setSessionCounter, setSessionIdGenerator, setSessionIdLength, setSessionMaxAliveTime, willAttributeDistribute
protected static final StringManager sm
protected static final long DEFAULT_REPL_TIMEOUT
protected java.lang.String name
public void messageDataReceived(ClusterMessage msg)
ClusterManager
messageDataReceived
in interface ClusterManager
msg
- - the message received.public ClusterMessage requestCompleted(java.lang.String sessionId)
ClusterManager
requestCompleted
in interface ClusterManager
sessionId
- - the sessionId that just completed.public void objectMadePrimary(java.lang.Object key, java.lang.Object value)
objectMadePrimary
in interface AbstractReplicatedMap.MapOwner
public Session createEmptySession()
Manager
createEmptySession
in interface Manager
createEmptySession
in class ManagerBase
public java.lang.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 java.lang.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(java.lang.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 java.lang.String[] getInvalidatedSessions()
ClusterManager
getInvalidatedSessions
in interface ClusterManager
public ClusterManager cloneFromTemplate()
cloneFromTemplate
in interface ClusterManager
public int getActiveSessionsFull()
DistributedManager
getActiveSessionsFull
in interface DistributedManager
public java.util.Set<java.lang.String> getSessionIdsFull()
DistributedManager
getSessionIdsFull
in interface DistributedManager
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.