public class CarbonTomcatClusterableSessionManager
extends org.apache.catalina.ha.session.DeltaManager
Modifier and Type | Field and Description |
---|---|
protected static org.apache.tomcat.util.res.StringManager |
sm
The string manager for this package.
|
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
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 |
---|
CarbonTomcatClusterableSessionManager() |
CarbonTomcatClusterableSessionManager(int ownerTenantId) |
Modifier and Type | Method and Description |
---|---|
void |
changeSessionId(org.apache.catalina.Session session,
boolean notify) |
org.apache.catalina.ha.ClusterManager |
cloneFromTemplate() |
void |
clusterMessageReceived(org.apache.catalina.ha.ClusterMessage msg) |
org.apache.catalina.Session |
findSession(String id) |
org.apache.catalina.Session[] |
findSessions() |
int |
getActiveSessions() |
void |
getAllClusterSessions() |
long |
getExpiredSessions() |
int |
getMaxActive() |
int |
getMaxInactiveInterval() |
Map<String,CarbonTomcatSessionMessage> |
getQueuedSessionMsgMap() |
int |
getRejectedSessions() |
int |
getSessionAverageAliveTime() |
int |
getSessionMaxAliveTime() |
CarbonSessionReplicationMessage |
getSessionReplicationMessage(String sessionId,
boolean expires) |
protected void |
handleGET_ALL_SESSIONS(org.apache.catalina.ha.session.SessionMessage msg,
org.apache.catalina.tribes.Member sender) |
void |
replicateSessions(org.apache.catalina.Session session) |
protected void |
sendCreateSession(String sessionId,
org.apache.catalina.ha.session.DeltaSession session) |
protected void |
sendSessions(org.apache.catalina.tribes.Member sender,
org.apache.catalina.Session[] currentSessions,
long sendTimestamp) |
protected void |
sessionExpired(String id) |
void |
setOwnerTenantId(int ownerTenantId) |
changeSessionId, createEmptySession, createSession, createSession, deserializeDeltaRequest, deserializeSessionId, deserializeSessions, expireAllLocalSessions, findSessionMasterMember, getCounterNoStateTransfered, getCounterReceive_EVT_ALL_SESSION_DATA, getCounterReceive_EVT_ALL_SESSION_NOCONTEXTMANAGER, getCounterReceive_EVT_ALL_SESSION_TRANSFERCOMPLETE, getCounterReceive_EVT_CHANGE_SESSION_ID, getCounterReceive_EVT_GET_ALL_SESSIONS, getCounterReceive_EVT_SESSION_ACCESSED, getCounterReceive_EVT_SESSION_CREATED, getCounterReceive_EVT_SESSION_DELTA, getCounterReceive_EVT_SESSION_EXPIRED, getCounterSend_EVT_ALL_SESSION_DATA, getCounterSend_EVT_ALL_SESSION_TRANSFERCOMPLETE, getCounterSend_EVT_CHANGE_SESSION_ID, getCounterSend_EVT_GET_ALL_SESSIONS, getCounterSend_EVT_SESSION_ACCESSED, getCounterSend_EVT_SESSION_CREATED, getCounterSend_EVT_SESSION_DELTA, getCounterSend_EVT_SESSION_EXPIRED, getInfo, getInvalidatedSessions, getName, getNewDeltaSession, getProcessingTime, getReceivedQueueSize, getSendAllSessionsSize, getSendAllSessionsWaitTime, getSessionReplaceCounter, getStateTransfered, getStateTransferTimeout, handleALL_SESSION_DATA, handleALL_SESSION_NOCONTEXTMANAGER, handleALL_SESSION_TRANSFERCOMPLETE, handleCHANGE_SESSION_ID, handleSESSION_ACCESSED, handleSESSION_CREATED, handleSESSION_DELTA, handleSESSION_EXPIRED, isExpireSessionsOnShutdown, isNoContextManagerReceived, isNotifyContainerListenersOnReplication, isNotifySessionListenersOnReplication, isSendAllSessions, isStateTimestampDrop, messageDataReceived, messageReceived, requestCompleted, requestCompleted, resetStatistics, send, serializeDeltaRequest, serializeSessionId, serializeSessions, setExpireSessionsOnShutdown, setName, setNoContextManagerReceived, setNotifyContainerListenersOnReplication, setNotifySessionListenersOnReplication, setSendAllSessions, setSendAllSessionsSize, setSendAllSessionsWaitTime, setStateTimestampDrop, setStateTransfered, setStateTransferTimeout, startInternal, stopInternal, waitForSendAllSessions
clone, getClassLoaders, getClassLoaders, getCluster, getReplicationStream, getReplicationStream, getSessionAttributeFilter, isNotifyListenersOnReplication, isRecordAllActions, load, registerSessionAtReplicationValve, setCluster, setNotifyListenersOnReplication, setRecordAllActions, setSessionAttributeFilter, unload, willAttributeDistribute
add, addPropertyChangeListener, backgroundProcess, expireSession, generateSessionId, getClassName, getContainer, getCreationTime, getCreationTimestamp, getDistributable, getDomainInternal, getDuplicates, getEngine, getJvmRoute, getLastAccessedTime, getLastAccessedTimestamp, getMaxActiveSessions, getNewSession, getObjectNameKeyProperties, getProcessExpiresFrequency, getSecureRandomAlgorithm, getSecureRandomClass, getSecureRandomProvider, getSession, getSessionAttribute, getSessionAttributeNameFilter, getSessionAttributeNamePattern, getSessionAttributeValueClassNameFilter, getSessionAttributeValueClassNamePattern, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdGenerator, getSessionIdLength, getThisAccessedTime, getThisAccessedTimestamp, getWarnOnSessionAttributeFilterFailure, initInternal, listSessionIds, processExpires, remove, remove, removePropertyChangeListener, setContainer, 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, getContainer, getDistributable, getSessionCounter, getSessionCreateRate, getSessionExpireRate, getSessionIdLength, remove, remove, removePropertyChangeListener, setContainer, setDistributable, setExpiredSessions, setMaxActive, setMaxInactiveInterval, setSessionCounter, setSessionIdLength, setSessionMaxAliveTime, willAttributeDistribute
protected static final org.apache.tomcat.util.res.StringManager sm
public CarbonTomcatClusterableSessionManager()
public CarbonTomcatClusterableSessionManager(int ownerTenantId)
public void setOwnerTenantId(int ownerTenantId)
public int getRejectedSessions()
getRejectedSessions
in interface org.apache.catalina.Manager
getRejectedSessions
in class org.apache.catalina.session.ManagerBase
public long getExpiredSessions()
getExpiredSessions
in interface org.apache.catalina.Manager
getExpiredSessions
in class org.apache.catalina.session.ManagerBase
public int getMaxInactiveInterval()
getMaxInactiveInterval
in interface org.apache.catalina.Manager
getMaxInactiveInterval
in class org.apache.catalina.session.ManagerBase
public org.apache.catalina.Session findSession(String id) throws IOException
findSession
in interface org.apache.catalina.Manager
findSession
in class org.apache.catalina.session.ManagerBase
IOException
public org.apache.catalina.Session[] findSessions()
findSessions
in interface org.apache.catalina.Manager
findSessions
in class org.apache.catalina.session.ManagerBase
public int getMaxActive()
getMaxActive
in interface org.apache.catalina.Manager
getMaxActive
in class org.apache.catalina.session.ManagerBase
public int getSessionAverageAliveTime()
getSessionAverageAliveTime
in interface org.apache.catalina.Manager
getSessionAverageAliveTime
in class org.apache.catalina.session.ManagerBase
public int getSessionMaxAliveTime()
getSessionMaxAliveTime
in interface org.apache.catalina.Manager
getSessionMaxAliveTime
in class org.apache.catalina.session.ManagerBase
public int getActiveSessions()
getActiveSessions
in interface org.apache.catalina.Manager
getActiveSessions
in class org.apache.catalina.session.ManagerBase
public CarbonSessionReplicationMessage getSessionReplicationMessage(String sessionId, boolean expires)
public void replicateSessions(org.apache.catalina.Session session)
public void clusterMessageReceived(org.apache.catalina.ha.ClusterMessage msg)
protected void sessionExpired(String id)
sessionExpired
in class org.apache.catalina.ha.session.DeltaManager
protected void handleGET_ALL_SESSIONS(org.apache.catalina.ha.session.SessionMessage msg, org.apache.catalina.tribes.Member sender) throws IOException
handleGET_ALL_SESSIONS
in class org.apache.catalina.ha.session.DeltaManager
IOException
protected void sendSessions(org.apache.catalina.tribes.Member sender, org.apache.catalina.Session[] currentSessions, long sendTimestamp) throws IOException
sendSessions
in class org.apache.catalina.ha.session.DeltaManager
IOException
protected void sendCreateSession(String sessionId, org.apache.catalina.ha.session.DeltaSession session)
sendCreateSession
in class org.apache.catalina.ha.session.DeltaManager
public void changeSessionId(org.apache.catalina.Session session, boolean notify)
changeSessionId
in class org.apache.catalina.ha.session.DeltaManager
public void getAllClusterSessions()
getAllClusterSessions
in class org.apache.catalina.ha.session.DeltaManager
public org.apache.catalina.ha.ClusterManager cloneFromTemplate()
cloneFromTemplate
in interface org.apache.catalina.ha.ClusterManager
cloneFromTemplate
in class org.apache.catalina.ha.session.DeltaManager
public Map<String,CarbonTomcatSessionMessage> getQueuedSessionMsgMap()
Copyright © 2016 WSO2 Inc. All rights reserved.