public class BackupManager extends ClusterManagerBase implements AbstractReplicatedMap.MapOwner, DistributedManager
ManagerBase.SessionTiming
Modifier and Type | Field and Description |
---|---|
protected static long |
DEFAULT_REPL_TIMEOUT |
protected 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.
|
int |
getActiveSessionsFull()
Returns the total session count for primary, backup and proxy.
|
String[] |
getInvalidatedSessions()
When the manager expires session not tied to a request.
|
String |
getMapName() |
int |
getMapSendOptions() |
String |
getName()
Return the descriptive short name of this Manager implementation.
|
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 |
objectMadePrimary(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 |
setDistributable(boolean dist)
Set the distributable flag for the sessions supported by this
Manager.
|
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, getReplicationStream, getReplicationStream, getSessionAttributeFilter, isNotifyListenersOnReplication, load, registerSessionAtReplicationValve, setCluster, setNotifyListenersOnReplication, 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, getSessionAverageAliveTime, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionIdLength, getSessionMaxAliveTime, getThisAccessedTime, getThisAccessedTimestamp, initInternal, listSessionIds, processExpires, propertyChange, remove, remove, removePropertyChangeListener, setContainer, setContext, setDuplicates, setExpiredSessions, setMaxActive, setMaxActiveSessions, setMaxInactiveInterval, setProcessExpiresFrequency, setProcessingTime, setSecureRandomAlgorithm, setSecureRandomClass, setSecureRandomProvider, setSessionCounter, setSessionIdGenerator, setSessionIdLength, setSessionMaxAliveTime, toString, updateSessionMaxAliveTime
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, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setSessionCounter, setSessionIdGenerator, setSessionIdLength, setSessionMaxAliveTime
protected static final StringManager sm
protected static final long DEFAULT_REPL_TIMEOUT
protected String name
public void messageDataReceived(ClusterMessage msg)
ClusterManager
messageDataReceived
in interface ClusterManager
msg
- - the message received.public ClusterMessage requestCompleted(String sessionId)
ClusterManager
requestCompleted
in interface ClusterManager
sessionId
- - the sessionId that just completed.public void objectMadePrimary(Object key, Object value)
objectMadePrimary
in interface AbstractReplicatedMap.MapOwner
public Session createEmptySession()
ManagerBase
createEmptySession
in interface Manager
createEmptySession
in class ManagerBase
public String getName()
ManagerBase
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 setDistributable(boolean dist)
ManagerBase
setDistributable
in interface Manager
setDistributable
in class ManagerBase
dist
- The new distributable flagpublic 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 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-2014 Apache Software Foundation. All Rights Reserved.