| Method Summary |
|
| public void | addLifecycleListener(LifecycleListener listener)
Add a lifecycle event listener to this component. |
| protected boolean | checkSenderDomain(SessionMessage msg, Member sender)
|
| public ClusterManager | cloneFromTemplate()
|
| public Session | createEmptySession()
|
| public Session | createSession(String sessionId)
Construct and return a new session object, based on the default settings
specified by this Manager's properties. |
| public Session | createSession(String sessionId, boolean distribute)
create new session with check maxActiveSessions and send session creation
to other cluster nodes. |
| protected DeltaRequest | deserializeDeltaRequest(DeltaSession session, byte[] data)
|
| protected void | deserializeSessions(byte[] data)
Load sessions from other cluster node. |
| public boolean | doDomainReplication()
|
| public void | expireAllLocalSessions()
Exipre all find sessions. |
| public LifecycleListener[] | findLifecycleListeners()
Get the lifecycle listeners associated with this lifecycle. |
| protected Member | findSessionMasterMember()
|
| public synchronized void | getAllClusterSessions()
|
| public CatalinaCluster | getCluster()
|
| public int | getCounterNoStateTransfered()
|
| public long | getCounterReceive_EVT_ALL_SESSION_DATA()
|
| public int | getCounterReceive_EVT_ALL_SESSION_TRANSFERCOMPLETE()
|
| public long | getCounterReceive_EVT_GET_ALL_SESSIONS()
|
| public long | getCounterReceive_EVT_SESSION_ACCESSED()
|
| public long | getCounterReceive_EVT_SESSION_CREATED()
|
| public long | getCounterReceive_EVT_SESSION_DELTA()
|
| public long | getCounterReceive_EVT_SESSION_EXPIRED()
|
| public long | getCounterSend_EVT_ALL_SESSION_DATA()
|
| public int | getCounterSend_EVT_ALL_SESSION_TRANSFERCOMPLETE()
|
| public long | getCounterSend_EVT_GET_ALL_SESSIONS()
|
| public long | getCounterSend_EVT_SESSION_ACCESSED()
|
| public long | getCounterSend_EVT_SESSION_CREATED()
|
| public long | getCounterSend_EVT_SESSION_DELTA()
|
| public long | getCounterSend_EVT_SESSION_EXPIRED()
|
| public String | getInfo()
Return descriptive information about this Manager implementation and the
corresponding version number, in the format
<description>/<version>. |
| public String[] | getInvalidatedSessions()
When the manager expires session not tied to a request. |
| public int | getMaxActiveSessions()
Return the maximum number of active Sessions allowed, or -1 for no limit. |
| public String | getName()
Return the descriptive short name of this Manager implementation. |
| protected DeltaSession | getNewDeltaSession()
Get new session class to be used in the doLoad() method. |
| public long | getProcessingTime()
|
| public int | getReceivedQueueSize()
|
| public int | getRejectedSessions()
|
| public int | getSendAllSessionsSize()
|
| public int | getSendAllSessionsWaitTime()
|
| public long | getSessionReplaceCounter()
|
| public int | getStateTransferTimeout()
|
| public boolean | getStateTransfered()
|
| protected void | handleALL_SESSION_DATA(SessionMessage msg, Member sender)
|
| protected void | handleALL_SESSION_TRANSFERCOMPLETE(SessionMessage msg, Member sender)
|
| protected void | handleGET_ALL_SESSIONS(SessionMessage msg, Member sender)
|
| protected void | handleSESSION_ACCESSED(SessionMessage msg, Member sender)
|
| protected void | handleSESSION_CREATED(SessionMessage msg, Member sender)
|
| protected void | handleSESSION_DELTA(SessionMessage msg, Member sender)
|
| protected void | handleSESSION_EXPIRED(SessionMessage msg, Member sender)
|
| public boolean | isDefaultMode()
|
| public boolean | isExpireSessionsOnShutdown()
|
| public boolean | isNotifyListenersOnReplication()
|
| public boolean | isNotifySessionListenersOnReplication()
|
| public boolean | isSendAllSessions()
|
| public boolean | isStateTimestampDrop()
|
| public void | load()
|
| public void | messageDataReceived(ClusterMessage cmsg)
A message was received from another node, this is the callback method to
implement if you are interested in receiving replication messages. |
| protected void | messageReceived(SessionMessage msg, Member sender)
This method is called by the received thread when a SessionMessage has
been received from one of the other nodes in the cluster. |
| public void | propertyChange(PropertyChangeEvent event)
Process property change events from our associated Context. |
| protected void | registerSessionAtReplicationValve(DeltaSession session)
|
| public void | removeLifecycleListener(LifecycleListener listener)
Remove a lifecycle event listener from this component. |
| public 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. |
| public synchronized void | resetStatistics()
|
| protected void | send(SessionMessage msg)
|
| protected void | sendCreateSession(String sessionId, DeltaSession session)
|
| protected void | sendSessions(Member sender, Session[] currentSessions, long sendTimestamp)
|
| protected byte[] | serializeDeltaRequest(DeltaRequest deltaRequest)
|
| protected byte[] | serializeSessions(Session[] currentSessions)
Save any currently active sessions in the appropriate persistence
mechanism, if any. |
| protected void | sessionExpired(String id)
|
| public void | setCluster(CatalinaCluster cluster)
|
| public void | setContainer(Container container)
Set the Container with which this Manager has been associated. |
| public void | setDefaultMode(boolean defaultMode)
|
| public void | setDomainReplication(boolean sendClusterDomainOnly)
|
| public void | setExpireSessionsOnShutdown(boolean expireSessionsOnShutdown)
|
| public void | setMaxActiveSessions(int max)
Set the maximum number of actives Sessions allowed, or -1 for no limit. |
| public void | setName(String name)
|
| public void | setNotifyListenersOnReplication(boolean notifyListenersOnReplication)
|
| public void | setNotifySessionListenersOnReplication(boolean notifyListenersCreateSessionOnReplication)
|
| public void | setRejectedSessions(int rejectedSessions)
|
| public void | setSendAllSessions(boolean sendAllSessions)
|
| public void | setSendAllSessionsSize(int sendAllSessionsSize)
|
| public void | setSendAllSessionsWaitTime(int sendAllSessionsWaitTime)
|
| public void | setStateTimestampDrop(boolean isTimestampDrop)
|
| public void | setStateTransferTimeout(int timeoutAllSession)
|
| public void | setStateTransfered(boolean stateTransfered)
|
| public void | start()
Prepare for the beginning of active use of the public methods of this
component. |
| public void | stop()
Gracefully terminate the active use of the public methods of this
component. |
| public void | unload()
|
| protected void | waitForSendAllSessions(long beforeSendTime)
|
